source-flink-sink實現端到端的狀態一致性

端到端（end-to-end）狀態一致性 端到端的一致性保證，意味着結果的正確性貫穿了整個流處理應用的始終；每一個組件都保證了它自己的一致性，整個端到端的一致性級別取決於所有組件中一致性最弱的組件。具體可以劃分如下： 內部保證 —— 依賴checkpoint source 端 —— 需要外部源可重設數據的讀取位置（kafka/rocketmq） sink 端 —— 需要保證從故障恢復時，數據不會重

>>阅读原文<<