Hey folks,

The Flink Kafka Connector still needs to move to the Flink 2.0-preview base 
(FLINK-36648 [1]) and remove the old Sink V1 API (FLINK-36245 [2]).

The connector also has a lot of deprecated classes. The docs say that the 
FlinkKafkaConsumer and FlinkKafkaProducer were supposed to be removed in 1.17 
and 1.15 respectively, but they are still there. Many of the usages of the old 
APIs are in these classes. So I was wondering if it would make sense to remove 
all these deprecated classes first? We could then do the move to Flink 2.0 more 
easily?

I assume that would also need the connector to move to a 4.0 release? 

I would be happy to have a go at the removal, but will probably hit some knotty 
legacy issues along the way so it would be great if there was someone with 
knowledge of the Kafka connector who would be open to a few questions? 

I also have a PR [3] up for moving the connector Kafka Client library to the 
3.9.0 version if anyone has time to review?

Tom Cooper

[1] https://issues.apache.org/jira/browse/FLINK-36648
[2] https://issues.apache.org/jira/browse/FLINK-36245
[3] https://github.com/apache/flink-connector-kafka/pull/138

Reply via email to