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

Thu, 25 Aug 2022 03:41:23 -0700 

您好，集群版本是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);
>>

回复