Hi Jing, I realized that there is a missing feature with KafkaSource that might prevent existing users of FlinkKafkaConsumer from migrating to FlinkKafkaConsumer. I have put more details in the discussion thread.
Thanks, Dong On Wed, Nov 16, 2022 at 12:37 AM Jing Ge <j...@ververica.com.invalid> wrote: > Hi, > > As discussed on the mailing list[1]. I'd like to start a vote to remove > FlinkKafkaConsumer and graduate related Source APIs. > > Since there are some ongoing developments which will change SinkV2 APIs, > depending on how far it would go, I might start another vote to remove > FlinkKafkaProducer before the coding freeze of 1.17 release. > > Voting will be open for at least 72 hours. > > Best regards, > Jing > > [1] https://lists.apache.org/thread/m3o48c2d8j9g5t9s89hqs6qvr924s71o >
