土法炼钢兴趣小组的算法知识备份

【流式数据处理】交付语义：从 at-most-once 到 exactly-once

2026-07-01 | database · distributed | #flink #delivery-semantics #exactly-once #at-least-once #at-most-once #checkpoint #kafka #idempotent #fault-tolerance

用 Source、引擎、Sink 三层模型拆解 at-most-once、at-least-once、exactly-once 的组合规则与最弱环决定律；对照 Flink checkpoint 模式、Kafka 事务与幂等 producer、重复消费/重复写入的三类修复手段，为两阶段提交 sink 铺垫。