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

# Kafka 事务与端到端一致性（2025） 端到端一致性需要在生产、消费与持久化之间协同保障。 ## 一、幂等生产与事务 - 幂等生产：避免重复消息；配置生产者幂等与重试。 - 事务：将多个写入合并为原子操作，保障一致性。 ## 二、Exactly-once (EOS) - EOS：在流处理与下游写入之间实现 Exactly-once。 - 偏移与状态：对偏移与状态进行一致性管理。 ## 三、Outbox 模式 - Outbox：在数据库写入伴随消息持久化，异步投递。 - 去重：在消费端按 Outbox 主键去重，防止重复。 ## 四、观测与回溯 - 观测：滞后与重复率与失败率监控。 - 回溯：在异常时进行补偿与回放。 ## 注意事项 - 关键词、分类与描述与正文一致；术语与能力为通用与可验证实践。 - 以业务一致性为准则选择 EOS 与 Outbox 的边界。