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
相關文章
相關標籤/搜索