flink sink kafka from checkpoint run failed

[maokeluo]

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/

[tianxy]

我也遇到了 请问你解决了没




--
Sent from: http://apache-flink.147419.n8.nabble.com/