Hi Dev, I'd like to start a discussion about removing FlinkKafkaConsumer and FlinkKafkaProducer in 1.17.
Back in the past, it was originally announced to remove it with Flink 1.15 after Flink 1.14 had been released[1]. And then postponed to the next 1.15 release which meant to remove it with Flink 1.16 but forgot to change the doc[2]. I have created a PRs to fix it. Since the 1.16 release branch has code freeze, it makes sense to, first of all, update the doc to say that FlinkKafkaConsumer will be removed with Flink 1.17 [3][4] and second start the discussion about removing them with the current master branch i.e. for the coming 1.17 release. I'm all ears and looking forward to your feedback. Thanks! Best regards, Jing [1] https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/kafka/#kafka-sourcefunction [2] https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/datastream/kafka/#kafka-sourcefunction [3] https://github.com/apache/flink/pull/21172 [4] https://github.com/apache/flink/pull/21171
