Hi, You can't use the released Flink 1.14 to connect to a Kafka 0.9 cluster. If you want to do it yourself, you would have to change the Flink source code to incorporate the downgrade and all the API changes from the currently used Kafka Client version (v2.4.1) [1] to a version that is still compatible with Kafka 0.9. This is because Kafka introduced bi-directional client compatibility as of Kafka 0.10 [2]. I doubt that this is realistically possible.
Best regards, Martijn [1] https://github.com/apache/flink/blob/release-1.14/flink-connectors/flink-connector-kafka/pom.xml#L39 [2] https://www.confluent.io/blog/upgrading-apache-kafka-clients-just-got-easier/ Op vr 1 jul. 2022 om 18:10 schreef hjw <[email protected]>: > Flink 1.14 Document display Flink 1.14 kafka connector only backwards > compatible with broker versions 0.10.0 or later. > Unfortunately, I have to use Flink 1.14 comsume Kafka 0.9 version? How can > I do it ？thx. > > >
