Flink 往kafka生产数据,频繁出现checkpoint失败的错误

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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


>>大佬们有遇到过吗?
>>不胜感激!