Flink Kafka 端到端 Exactly-Once 分析

摘要：本文基於 Flink 1.9.0 和 Kafka 2.3 版本，對 Flink kafka 端到端 Exactly-Once 進行分析及 notifyCheckpointComplete 順序，主要內容分爲如下兩部分：html 1.Flink-kafka 兩階段提交源碼分析java TwoPhaseCommitSinkFunction 分析ios 2.Flink 中 notifyCheckp

>>阅读原文<<