You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by hjw <10...@qq.com> on 2022/07/01 16:09:13 UTC
Does Flink 1.14 support comsume Kafka 0.9?
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.
Re: Does Flink 1.14 support comsume Kafka 0.9?
Posted by Martijn Visser <ma...@apache.org>.
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 <10...@qq.com>:
> 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.
>
>
>