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

【流式数据处理】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 的调优边界。