Re: flink sink kafka from checkpoint run failed

我也遇到了 请问你解决了没 -- Sent from: http://apache-flink.147419.n8.nabble.com/

flink sink kafka from checkpoint run failed

flink: 1.11.2 kafka:2.11 发送数据到kafka，任务运行一段时间后取消，从checkpoint重新启动，任务启动失败，报错：org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default producerId at version 1。 查看kafka-client未发现相关的异常message -- Sent from: http://apache-flink.147419.n8.nabble.com/