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
相关文章
相关标签/搜索