enable.idempotence=true仅保障单会话单分区幂等，必须与acks=all、retries为大值、max.in.flight.requests.per.connection=1协同生效；跨会话、跨分区及消费者端重复需业务层唯一id+去重存储兜底。
enable.idempotence=true 能解决部分重复问题，但**绝不能单独启用**——它只在单会话、单分区内生效，且依赖 acks=all、retries、max.in.flight.requests.per.connection 三者协同才能真正起作用。
为什么只设 enable.idempotence=true 是无效的
Kafka 的幂等性靠 PID + 每个 topic-partition 上的 SequenceNumber 校验。一旦 Producer 进程重启，PID 重置，旧序列号状态全丢；发往不同 Partition 的消息序列号互不干扰；Broker 更不会管你这条“创建订单”和上一条是不是语义重复。
所以常见错误现象包括：
- 服务滚动更新后，同一条消息被重复写入多个 Partition
- 网络抖动触发重试，但因
max.in.flight.requests.per.connection > 1导致乱序，Broker 拒绝后续请求并报错OutOfOrderSequenceException -
acks=1时 Leader 写完就返回，ISR 副本还没同步，恰好 Leader 挂了，重试后又写一遍
Confluent Kafka Go 客户端必须配齐的四项参数
用 confluent-kafka-go（推荐）而非 sarama 或 kafka-go，因后者不原生支持幂等性配置项。关键不是“开了就行”，而是四者缺一不可：
-
"enable.idempotence": "true"：开启幂等开关 -
"acks": "all"：强制等待 ISR 全部写入，否则序列号校验形同虚设 -
"retries": "2147483647"：设为最大整数（Go 中int(^uint(0) >> 1)），确保可恢复错误必重试 -
"max.in.flight.requests.per.connection": "1"：Kafka 3.0 之前必须为 1；3.0+ 可设为 5，但需确认 Broker 版本并配合enable.idempotence=true
漏掉任意一项，enable.idempotence=true 都会被静默降级，日志里甚至不报错。
Golang Uber Dig
下载
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
业务层仍需唯一 ID + 去重存储
跨会话、跨分区、消费者崩溃重拉——这些场景 enable.idempotence 完全不管。此时必须由业务自己兜底：
- Producer 发送前生成带业务上下文的 ID，例如
"order_created:20260714-ORD-8892"，不能只哈希原始消息体（不同业务线可能撞哈希） - Consumer 端用 Redis
SET key value EX 3600 NX原子校验，EX 时间要 ≥ 业务处理最大耗时 × 2（如处理最长 20s，EX 至少设 40s） - 若
SETNX返回 false，直接return nil，不要panic、不要err、不要提交 offset —— 否则框架自动重试会放大问题 - 别依赖数据库唯一约束做幂等：冲突时事务已执行一半，通知发了、外部接口调了，DB 报错只是“事后发现”，不是“事前拦截”
并发消费同一条消息时的正确响应方式
多个 Consumer 实例或 goroutine 同时拿到同一条消息是常态，尤其在 rebalance 后。这时幂等校验必须原子且收尾干净：
- 成功拿到
SETNX的 goroutine 执行业务逻辑，完成后才提交该消息的 offset - 其余 goroutine 收到
false后，仅记录日志"duplicate message skipped: order_created:20260714-ORD-8892"，然后return nil - offset 提交时机必须和
SETNX成功强绑定：只有校验通过 + 业务完成，才允许提交；否则不提交，让 Kafka 自动重推 - Redis key 必须含 topic 名，例如
"idempotent:orders:order_created:20260714-ORD-8892"，避免多 topic 共用 key 空间导致误判
最容易被忽略的是：幂等校验和 offset 提交之间不能有 gap。哪怕只差一行 defer 或异步 goroutine，都可能造成“校验通过但 offset 没提交”，下次拉取又来一遍。
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
