flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ddwcg <3149768...@qq.com>
Subject Re: 关于flink 写于kafka时的transactionId 生成问题
Date Thu, 29 Aug 2019 09:50:09 GMT
broker就一个,flink集群的时钟确实和broker的不一样,是不同的机房,能自己指定transactionalId吗,两个机房的调整成一样怕影响其他的应用

> 在 2019年8月29日,17:45,Wesley Peng <weslepeng@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.
> 




Mime
View raw message