[ https://issues.apache.org/jira/browse/FLINK-25729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617831#comment-17617831 ]
Danny Cranmer commented on FLINK-25729: --------------------------------------- Yes I believe so, resolving this as duplicate > Replace the deprecated FlinkKinesisConsumer with a Kinesis Consumer based on > the AWS SDK for Java 2.x > ----------------------------------------------------------------------------------------------------- > > Key: FLINK-25729 > URL: https://issues.apache.org/jira/browse/FLINK-25729 > Project: Flink > Issue Type: Improvement > Components: Connectors / Kinesis > Affects Versions: 1.15.0 > Reporter: Zichen Liu > Priority: Major > > h2. Motivation > *User stories:* > As a Flink user, I’d like to use a Kinesis Consumer based on the AWS SDK for > Java 2.x rather than the Kinesis Consumer Library. > > * Maintain all the features of the current consumer at > `org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer` in the > new source > * The new sink should live in the module > `flink-connector-aws-kinesis-streams` (old: `flink-connector-kinesis`) -- This message was sent by Atlassian Jira (v8.20.10#820010)