Re: Re: Flink support for Kafka versions

2021-10-27 Thread Arvid Heise
Hi Prasanna, we cannot backport these changes as they change dependency coordinates. What I'd recommend you to do is to use the Flink 2_12 dependencies and then bump Kafka client to 2.8.X in your application jar. That should work in any case. Best, Arvid On Wed, Oct 27, 2021 at 12:05 PM Yun Ga

Re: Re: Flink support for Kafka versions

2021-10-27 Thread Yun Gao
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