flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Wesley Peng <weslep...@gmail.com>
Subject Re: 关于flink 写于kafka时的transactionId 生成问题
Date Thu, 29 Aug 2019 09:45:19 GMT

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.


View raw message