土法炼钢 · 系统与基础设施

【流式数据处理】Checkpoint 机制：Barrier 对齐与一致性快照

2026-07-01 | database · distributed | #flink #checkpoint #chandy-lamport #barrier #kafka #exactly-once #backpressure #fault-tolerance

从 Chandy-Lamport 分布式快照到 Flink aligned/unaligned checkpoint：CheckpointCoordinator 触发—ack—完成生命周期，Kafka source 如何把 partition offset 写入 checkpoint，以及 interval、timeout、min-pause、concurrent checkpoints 的调优边界。