大佬们好. flink exactly once 写kafka,如果flink checkpoint超时了导致kafka的transaction在commit之前也超时了, flink会怎么处理呢? kafka的transaction因为超时,abort后, 会导致abort之前写kafka的数据,丢失吗?
- flink exactly once 写kafka,如果checkpoint超时了导致kafka的transaction在c... 郑 致远
大佬们好. flink exactly once 写kafka,如果flink checkpoint超时了导致kafka的transaction在commit之前也超时了, flink会怎么处理呢? kafka的transaction因为超时,abort后, 会导致abort之前写kafka的数据,丢失吗?