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 >>> >>
