You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 胡云川 <hu...@foxmail.com> on 2020/07/21 03:40:32 UTC
Flink 往kafka生产数据，频繁出现checkpoint失败的错误
>>>>大佬们好，
>>>>在Flink 往kafka生产数据的时候，频繁出席那checkpoint失败的错误，开启EXACTLY_ONCE
>>报错代码如下：
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
>>大佬们有遇到过吗？
>>不胜感激！