Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25731

Mark FlinkKinesisProducer/FlinkKinesisConsumer as deprecated

    XMLWordPrintableJSON

Details

    Description

      This consumer based on the Kinesis Consumer Library (KCL) has been deprecated, a Jira to create an equivalent consumer based on AWS SDK for Java 2.x has been raised in FLINK-25729 and planned for Flink 1.16.

      This producer based on the Kinesis Producer Library KPL has been superseded. The new sink can be found in the module flink-connectors/flink-connector-aws-kinesis-data-streams and package org.apache.flink.connector.kinesis.sink.KinesisDataStreamsSink. It is based on the AWS SDK for Java 2.x. The work to replace this sink was carried out in FLINK-24227.

      Attachments

        Issue Links

          Activity

            People

              CrynetLogistics Zichen Liu
              CrynetLogistics Zichen Liu
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: