broker就一个，flink集群的时钟确实和broker的不一样，是不同的机房，能自己指定transactionalId吗，两个机房的调整成一样怕影响其他的应用
> 在 2019年8月29日，17:45，Wesley Peng <weslep...@gmail.com> 写道： > > 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. >
