Flink生產數據到Kafka頻繁出現事務失效導致任務重啟
在生產中需要將一些數據發到kafka,而且需要做到EXACTLY_ONCE,kafka使用的版本為1.1.0,flink的版本為1.8.0,但是會很經常因為提交事務引起錯誤,甚至導致任務重啟 kaf ...
在生產中需要將一些數據發到kafka,而且需要做到EXACTLY_ONCE,kafka使用的版本為1.1.0,flink的版本為1.8.0,但是會很經常因為提交事務引起錯誤,甚至導致任務重啟 kaf ...