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

Fri, 26 Aug 2022 02:35:38 -0700 

感谢回复，我这边问题已经修复了，修改一下clients的版本到2.4.1就可以了

















在 2022-08-26 16:20:27，"Weihua Hu" <huweihua....@gmail.com> 写道：
>可以尝试升级到 2.5+
>
>Best,
>Weihua
>
>
>On Thu, Aug 25, 2022 at 6:41 PM gulugulucxg <gulugulu...@163.com> wrote:
>
>> 您好，集群版本是1.1.1，是挺低的，是这个原因吗，升级到多少合适呢
>> 在 2022-08-25 18:31:06，"Weihua Hu" <huweihua....@gmail.com> 写道：
>> >kafka 集群的版本是什么呢？看起来是集群版本有点低了
>> >
>> >Best,
>> >Weihua
>> >
>> >
>> >On Thu, Aug 25, 2022 at 3:41 PM gulugulucxg <gulugulu...@163.com> 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.UnsupportedVersionException: Attempted
>> to write a non-default producerId at version 0
>> >>
>> >> 相关代码如下：
>> >>         Properties properties = new Properties();
>> >>         properties.put("bootstrap.servers",
>> >> KafkaConstant.bootstrap_servers_01);
>> >>         properties.put("transaction.timeout.ms", 15 * 60 * 1000);
>> >>         FlinkKafkaProducer<String> statsLogV2Producer = new
>> >> FlinkKafkaProducer<>(
>> >>                 KafkaConstant.topic_01,
>> >>                 new MyKafkaSerializationSchema(KafkaConstant.topic_01),
>> >>                 properties ,
>> >>                 FlinkKafkaProducer.Semantic.EXACTLY_ONCE);
>> >>
>>

回复