Hi on 2019/8/29 17:13, ddwcg wrote:
作业我已经停止了，但是看kafka的日志还是不断的在刷Initialized transactionalId………. ，而且该程序再此启动就会报： Caused by: org.apache.kafka.common.errors.ProducerFencedException: Producer attempted an operation with an old epoch. Either there is a newer producer with the same transactionalId, or the producer's transaction has been expired by the broker. 错误，请问有什么办法可以避免这个问题？
Maybe you want to check all the broker and producers have the same timezone setup, and all time are synchronous.
regards.
