flink kafka 保證 Exactly Once 語義

flink 通過checkpoint機制來定期保存計算任務的快照，包含兩個重要的參數： 1、整個計算任務的狀態， 2、數據源的位置信息，比如kafka的offset flink通過數據流中插入一個barrier（屏障）來確保checkpoint中的位置和狀態完全對應 kafka的exactly once語義通過事務和生產冪等共同實現 端到端的exactly once指的是數據從kafka的A主題消

>>阅读原文<<