本文探讨了流式数据处理中的交付语义，重点分析了Flink的checkpoint机制与Kafka的offset管理。建立了三层模型：Source、引擎和Sink，讨论了at-most-once、at-least-once和exactly-once的定义及修复手段。强调端到端语义由最弱环决定，指出即使使用exactly-once，Sink仍需支持2PC或幂等操作，以避免重复写入。