[FLINK-25731] Mark FlinkKinesisProducer/FlinkKinesisConsumer as deprecated

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.15.0
• Component/s: Connectors / Common
• Labels: pull-request-available
• Assignee: Zichen Liu
• Reporter: Zichen Liu
• Created: 20/Jan/22 11:20
• Updated: 26/Jan/22 15:16
• Resolved: 26/Jan/22 15:16

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.

Issue Links

• is a clone of: FLINK-24229 DynamoDB implementation of Async Sink
• links to: GitHub Pull Request #18421