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:31:29 -0700 

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);
>

回复