|
>>>>大佬们好,
>>>>在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
>>大佬们有遇到过吗?
>>不胜感激!
|