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
