Flink Kafka 端到端 Exactly-Once 分析 Flink Kafka 端到端 Exactly-Once 分析 本文基于 Flink 1.9.0 和 Kafka 2.3 版本，对 Flink kafka 端到端 Exactly-Once 进行分析及 notifyCheckpointComplete 顺序，主要内容分为以下两部分：1.Flink-kafka 两阶段提交源码分析；2.Flink 中 notifyCheckpointComplete 方法调用顺序
谈谈流计算中的『Exactly Once』特性 谈谈流计算中的『Exactly Once』特性 本文翻译自 streaml.io 网站上的一篇博文：“Exactly once is NOT exactly the same” ，分析了流计算系统中常说的『Exactly Once』特性，主要观点是：『精确一次』并不保证是完全一样。
Apache Flink 结合 Kafka 构建端到端的 Exactly-Once 处理 Apache Flink 结合 Kafka 构建端到端的 Exactly-Once 处理 描述Flink checkpoint机制是如何保证Flink程序结果的Exactly-Once的 显示Flink如何通过两阶段提交协议与数据源和数据输出端交互，以提供端到端的Exactly-Once保证 通过一个简单的示例，了解如何使用TwoPhaseCommitSinkFunction实现Exactly-Once的文件输出
浙公网安备 33010802010061号