Hi all, I've cherry-picked FLINK-30400 onto v3.0 branch of flink-connector-kafka.
Treating this thread as justification to start a vote for 3.0.2 RC #1 immediately so we can get out a new release ASAP. Please see the vote thread here [1]. @guenterh.lists <guenterh.li...@bluewin.ch> Would you be able to test this RC and see if the issue is resolved for you? It should work simply by having a dependency on flink-streaming-java and flink-clients for 1.18.0, as well as flink-connector-kafka 3.0.2-18. The flink-connector-base dependency you added in the end as a workaround should not be needed. Thanks, Gordon [1] https://lists.apache.org/thread/34zb5pnymfltrz607wqcb99h7675zdpj On Fri, Nov 24, 2023 at 5:16 AM Leonard Xu <xbjt...@gmail.com> wrote: > > > - built a fat uber jar from quickstart with Flink 1.18.0 for > flink-streaming-java and flink-clients, and flink-connector-kafka version > 3.0.1-1.18 > - then submitted to local Flink cluster 1.18.0. Things worked as > expected and the job ran fine. > > Hey，@Gordan > I guess things may work as expected when you submit your fat jar job to > cluster, because flink-connector-base （1.18.0 in this case) has been > included to flink-dist jar [1] which will appear in your classpath, but it > may meet issue when you run in local IDE environment, maybe you can have a > local test to verify this. > > In the end, I think we need to backport FLINK-30400 to the Flink Kafka > connector 3.0 branch and prepare a 3.0.2 soon. > > Best, > Leonard > [1] > https://github.com/apache/flink/blob/977463cce3ea0f88e2f184c30720bf4e8e97fd4a/flink-dist/pom.xml#L156 >
