请解释 Checkpoint 与 Kafka Offset 在 Flink 中的关联，以及两者如何共同保证端到端一致性。
考察说明
考察对 Flink 状态一致性机制和 Kafka 消费者位移管理的理解
回答思路
- 说明 Checkpoint 是 Flink 分布式快照机制，用于保存算子状态与偏移量
- 说明 Kafka Offset 作为 Flink 消费端状态的一部分被持久化在 Checkpoint 中
- 阐述 Checkpoint 成功后才提交 Kafka Offset，失败则从最近一次 Checkpoint 恢复
- 理解两者配合可达成 exactly-once 语义
本题已收录答题指导
本题附完整参考答案与评分标准
登录后可查看结构化答题指导；也可以直接开一场模拟面试，AI 面试官用本题实时追问并给出评分。