---

标题: Kafka 事务与端到端一致性（2025）

关键词:

• 事务
• 幂等生产
• Exactly-once
• EOS
• Outbox

描述: 结合幂等生产与事务与 Outbox，构建 Kafka 的端到端一致性链路，实现 Exactly-once 语义与可回溯处理。

categories:

• 文章资讯
• 编程技术

---

Kafka 事务与端到端一致性（2025）

端到端一致性需要在生产、消费与持久化之间协同保障。

一、幂等生产与事务

• 幂等生产：避免重复消息；配置生产者幂等与重试。
• 事务：将多个写入合并为原子操作，保障一致性。

二、Exactly-once (EOS)

• EOS：在流处理与下游写入之间实现 Exactly-once。
• 偏移与状态：对偏移与状态进行一致性管理。

三、Outbox 模式

• Outbox：在数据库写入伴随消息持久化，异步投递。
• 去重：在消费端按 Outbox 主键去重，防止重复。

四、观测与回溯

• 观测：滞后与重复率与失败率监控。
• 回溯：在异常时进行补偿与回放。

注意事项

• 关键词、分类与描述与正文一致；术语与能力为通用与可验证实践。
• 以业务一致性为准则选择 EOS 与 Outbox 的边界。