-
Notifications
You must be signed in to change notification settings - Fork 163
[FLINK-36821] Update to Kafka 3.9.0 #138
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) |
...n/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java
Outdated
Show resolved
Hide resolved
Whether the 3.9.0 version Kafka client is compability with the low version Kafka and zookeeper image? |
Yes, Kafka client 3.9.0 supports old version of Kafka and zookeeper image. |
Signed-off-by: Thomas Cooper <[email protected]>
This PR might be superseded by #161 if we want to move to Kafka 4.0.0 for the connector's 4.0 release. We could do a 3.5 release that has Flink 2.0 and Kafka 3.9 for those that need to retain access to very old kafka clusters (2.0 or earlier)? |
I'd prefer to have a release with 3.9 first. DataStream users are usually free to bump independent of this release anyways. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
CI is green. LGTM. Going to merge now.
Awesome work, congrats on your first merged pull request! |
Currently, the Flink Kafka Connector uses Kafka client version 3.4.0.
This has a medium severity vulnerability (CVE-2024-31141) and needs to be upgraded to >= 3.8.0 to address it.
3.9.0 is the most recently released version and between that and 3.4.0 there have been numerous bug and performance fixes.
This PR:
I am not familiar with ArchUnit, but it appears the violation file changes have been checked into previous commits so I have included them here aswell.