[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15254332#comment-15254332
]
ASF GitHub Bot commented on FLINK-3229:
---------------------------------------
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1911#issuecomment-213530765
Hi,
Cool, if you have time to adress them, go ahead :)
Thanks a lot for doing this by the way! I really like the work you did so
far on the connector!
Sent from my iPhone
> On 22.04.2016, at 18:01, Tzu-Li Tai <[email protected]> wrote:
>
> @rmetzger
> Thank you very much for your detailed review on the PR :)
> I've replied to the comments you added, please .
> I can address the issues and follow up with corresponding commits within
the next 36 hours. I am pretty much free for the next 3 days, and will very
much like to get the consumer ready for merging by the end of this week :)
>
> If it still isn't ready by the end of 4/25, I'm afraid I will have to
leave any remaining issues for you to address since after then I temporarily
won't be able to work on code until June.
>
> —
> You are receiving this because you were mentioned.
> Reply to this email directly or view it on GitHub
>
> Kinesis streaming consumer with integration of Flink's checkpointing mechanics
> ------------------------------------------------------------------------------
>
> Key: FLINK-3229
> URL: https://issues.apache.org/jira/browse/FLINK-3229
> Project: Flink
> Issue Type: Sub-task
> Components: Streaming Connectors
> Affects Versions: 1.0.0
> Reporter: Tzu-Li (Gordon) Tai
> Assignee: Tzu-Li (Gordon) Tai
>
> Opening a sub-task to implement data source consumer for Kinesis streaming
> connector (https://issues.apache.org/jira/browser/FLINK-3211).
> An example of the planned user API for Flink Kinesis Consumer:
> {code}
> Properties kinesisConfig = new Properties();
> config.put(KinesisConfigConstants.CONFIG_AWS_REGION, "us-east-1");
> config.put(KinesisConfigConstants.CONFIG_AWS_CREDENTIALS_PROVIDER_TYPE,
> "BASIC");
> config.put(
> KinesisConfigConstants.CONFIG_AWS_CREDENTIALS_PROVIDER_BASIC_ACCESSKEYID,
> "aws_access_key_id_here");
> config.put(
> KinesisConfigConstants.CONFIG_AWS_CREDENTIALS_PROVIDER_BASIC_SECRETKEY,
> "aws_secret_key_here");
> config.put(KinesisConfigConstants.CONFIG_STREAM_INIT_POSITION_TYPE,
> "LATEST"); // or TRIM_HORIZON
> DataStream<T> kinesisRecords = env.addSource(new FlinkKinesisConsumer<>(
> "kinesis_stream_name",
> new SimpleStringSchema(),
> kinesisConfig));
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
