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