Re:Re: Re: Flink Kafka Sink Error: org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default producerId at version 0

感谢回复，我这边问题已经修复了，修改一下clients的版本到2.4.1就可以了 在 2022-08-26 16:20:27，"Weihua Hu" 写道： >可以尝试升级到 2.5+ > >Best, >Weihua > > >On Thu, Aug 25, 2022 at 6:41 PM gulugulucxg wrote: > >> 您好，集群版本是1.1.1，是挺低的，是这个原因吗，升级到多少合适呢 >> 在 2022-08-25 18:31:06，"Weihua Hu" 写道： >> >kafka 集群的版本是什么呢？看起来是集群版本有点低了

Re: Re: Flink Kafka Sink Error: org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default producerId at version 0

可以尝试升级到 2.5+ Best, Weihua On Thu, Aug 25, 2022 at 6:41 PM gulugulucxg wrote: > 您好，集群版本是1.1.1，是挺低的，是这个原因吗，升级到多少合适呢 > 在 2022-08-25 18:31:06，"Weihua Hu" 写道： > >kafka 集群的版本是什么呢？看起来是集群版本有点低了 > > > >Best, > >Weihua > > > > > >On Thu, Aug 25, 2022 at 3:41 PM gulugulucxg wrote: > > > >> 大佬们好： > >> >

Re: Flink Kafka Sink Error: org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default producerId at version 0

kafka 集群的版本是什么呢？看起来是集群版本有点低了 Best, Weihua On Thu, Aug 25, 2022 at 3:41 PM gulugulucxg wrote: > 大佬们好： > > 我这边指定EXACTLY_ONCE写kafka后，任务直接起能起来，但是从savepoint起任务总是失败，kafka-clients版本2.5.0，flink版本及相关依赖版本均为1.12.4， > > 异常如下： > > 2022-08-25 10:42:44 > > org.apache.kafka.common.errors.UnsupportedVersionExc