You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/28 14:40:20 UTC

[jira] [Created] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp

Tzu-Li (Gordon) Tai created FLINK-4523:
------------------------------------------

             Summary: Allow Kinesis Consumer to start from specific timestamp
                 Key: FLINK-4523
                 URL: https://issues.apache.org/jira/browse/FLINK-4523
             Project: Flink
          Issue Type: New Feature
          Components: Kinesis Connector
            Reporter: Tzu-Li (Gordon) Tai
             Fix For: 1.2.0


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



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)