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

Thu, 25 Aug 2022 00:40:58 -0700 

大佬们好：
我这边指定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);

回复