Hi Jing, Thanks for opening the discussion. I see no issue with removing the FlinkKafkaConsumer, since it has been marked as deprecated and the Source API (which is used by the KafkaSource) is marked as @Public (at least the Base implementation)
The successor of the FlinkKafkaProducer is the KafkaSink, which is using the Sink V2 API which is still marked as @PublicEvolving (Base implementation). I think that we should only remove the FlinkKafkaProducer if we also mark the Sink V2 as @Public. I don't think that should be a problem (since it's based on the first Sink implementation, which was Experimental in 1.14 and got replaced with Sink V2 as PublicEvolving in 1.15). Thanks, Martijn On Thu, Oct 27, 2022 at 2:06 PM Jing Ge <j...@ververica.com> wrote: > 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 >
