Details
-
New Feature
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
Description
We had a Kinesis user requesting this feature on an offline chat.
To be specific, we let all initial Kinesis shards be iterated starting from records at the given timestamp.
The AWS Java SDK we're using already provides API for this, so we can add this functionality with fairly low overhead: http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/kinesis/model/GetShardIteratorRequest.html#setTimestamp-java.util.Date-
Attachments
Issue Links
- relates to
-
FLINK-5625 Let Date format for timestamp-based start position in Kinesis consumer be configurable.
- Closed
- links to