取值
| acks | 确认条件 | 风险 | 适用 |
|---|---|---|---|
| 0 | 发送即返回 | Broker 故障可能丢 | 允许丢失的埋点 |
| 1 | Leader 落盘即返回 | Leader 宕机且未复制则丢 | 一般业务日志 |
| all（-1） | ISR 全部确认 | ISR 不足时写入失败 | 账务、事件源 |
高持久性组合
高持久性组合
acks=all
enable.idempotence=true
min.insync.replicas=2 # 主题侧配置，与 acks=all 配合Kafka 3.0 起生产者默认 acks=all 且幂等开启，升级前确认旧客户端行为的差异。