Re:flink exactly once 写kafka,如果checkpoint超时了导致kafka的transaction在commit之前也超时了, flink会怎么处理呢?

Tue, 01 Nov 2022 08:08:14 -0700 

Hi, 应该会等到下一次做cp的时候再提交
在 2022-11-01 17:13:22，"郑 致远" <zehongzheng2...@hotmail.com> 写道：
>大佬们好.
>flink exactly once 写kafka,如果flink 
>checkpoint超时了导致kafka的transaction在commit之前也超时了, flink会怎么处理呢?
>kafka的transaction因为超时,abort后, 会导致abort之前写kafka的数据,丢失吗?

回复