Kafka 怎么配置生产者的确认模式与应答级别-java教程-PHP中文网

kafka生产者acks参数决定消息可靠性：acks=0发完即忘，acks=1仅leader确认（默认），acks=all需isr全部副本写入成功；搭配enable.idempotence=true、retries设大值及min.insync.replicas=2，并协同batch.size与linger.ms平衡吞吐与延迟。

kafka 怎么配置生产者的确认模式与应答级别

Kafka 生产者的确认模式（即 `acks`）直接决定消息写入的可靠性级别，它不是“开关式”的配置，而是通过一个字符串参数控制 Broker 的应答行为。核心就三点：**设什么值、为什么这么设、配套要调什么**。

acks 可选值及实际含义

生产者配置中 `acks` 参数只有三个合法取值，各自代表不同的一致性与性能权衡：

acks=0：发完即忘。不等待任何 Broker 确认，吞吐最高，但网络丢包、Broker 崩溃或磁盘写失败时，消息必然丢失。
acks=1（默认值）：只等 Leader 写入成功。Leader 收到并落盘即返回 ACK。若 Leader 在同步给 Follower 前宕机，且新选 Leader 没有该消息，就会丢失。
acks=all（等价于 acks=-1）：必须等 ISR（In-Sync Replicas）中所有副本都写入成功才返回 ACK。这是强持久性保障，只要 ISR 中至少有一个副本存活，消息就不会丢。

高可靠场景下的推荐配置组合

单设 `acks=all` 不够，需配合其他参数才能真正落地可靠性：

deep-java-review

Java项目代码review工具。分析Git变更+完整调用链路上下文，推断业务需求，进行多维度评分和分类汇总，生成完整PRD文档。包含细粒度Java代码审查清单（Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...

下载

启用幂等性：enable.idempotence=true。开启后自动将 max.in.flight.requests.per.connection 限制为 5，避免乱序重试导致重复；同时确保单分区“恰好一次”语义。
设置合理重试次数：retries=2147483647（或明确设为较大值如 10），配合幂等性，让临时网络抖动或 Leader 切换可自动恢复。
服务端配合：Broker 端需设置 min.insync.replicas=2（至少 2 个副本同步才算成功），否则 `acks=all` 可能退化为 `acks=1`。

Java 示例配置片段

以下是最常用的安全生产配置（非低延迟场景）：

props.put("bootstrap.servers", "k1:9092,k2:9092,k3:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("acks", "all");
props.put("enable.idempotence", "true");
props.put("retries", "10");
props.put("batch.size", "16384");
props.put("linger.ms", "5");