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

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