Hi Prasanna, I think the two issues would not be picked back to 1.12.x since they are all large modification and user-visiable and thus they should be not suitable to be picked back to the bugfix version. Which scala version are you going to use? Flink currently provided both version with scala 2.11 and scala 2.12 [1].
[1] https://flink.apache.org/downloads.html#apache-flink-1125 ------------------Original Mail ------------------ Sender:Prasanna kumar <prasannakumarram...@gmail.com> Send Date:Wed Oct 27 00:01:45 2021 Recipients:Arvid Heise <ar...@apache.org> CC:Austin Cawley-Edwards <austin.caw...@gmail.com>, user <user@flink.apache.org>, Chesnay Schepler <ches...@apache.org> Subject:Re: Flink support for Kafka versions Hi , We are using Kafka broker version 2.4.1.1. Also kafka client 2.4.1.1 jar which is part of flink kafka connector recently was marked with high security issue. So we excluded the dependency and overriden it with kafka client 2.8.1 client jar and it works fine with the 2.4.1.1 broker. ( since its backward compatible) 1) If we tried to connect to broker with 2.8.1 version (with kafka client 2.8.1 jar override ) would it work or would it throw errors because of Scala 2.11? 2) https://issues.apache.org/jira/browse/FLINK-20845 is marked as done but the fix version is marked as 1.15.0.. Wouldn't this change be available for 1.12.x ? 3) https://issues.apache.org/jira/browse/FLINK-14105 is marked as done but the fix version is marked as 1.14.0.. Wouldn't this change be available for 1.12.x ? Thanks, Prasanna. On Wed, Apr 21, 2021 at 11:03 PM Arvid Heise <ar...@apache.org> wrote: I'm wondering if we could shade scala 1.13 dependencies inside the Kafka connector? Then we would be independent of the rather big FLINK-20845. On Tue, Apr 20, 2021 at 5:54 PM Austin Cawley-Edwards <austin.caw...@gmail.com> wrote: Hi Prasanna, It looks like the Kafka 2.5.0 connector upgrade is tied to dropping support for Scala 2.11. The best place to track that would be the ticket for Scala 2.13 support, FLINK-13414 [1], and its subtask FLINK-20845 [2]. I have listed FLINK-20845 as a blocker for FLINK-19168 for better visibility. Best, Austin [1]: https://issues.apache.org/jira/browse/FLINK-13414 [2]: https://issues.apache.org/jira/browse/FLINK-20845 On Tue, Apr 20, 2021 at 9:08 AM Prasanna kumar <prasannakumarram...@gmail.com> wrote: Hi Flinksters, We are researching about if we could use the latest version of kafka (2.6.1 or 2.7.0) Since we are using Flink as a processor , we came across this https://issues.apache.org/jira/browse/FLINK-19168. It says that it does not support version 2.5.0 and beyond. That was created 8 months back , just checking if there is any effort on that front. Thanks, Prasanna
