Kafka 实战 - 生产者中的ack配置_kafka acks 配置

在Apache Kafka中，生产者通过acks配置参数来控制消息写入Kafka集群后的确认级别，进而影响消息的可靠性。acks配置决定了生产者在何时认为消息发送成功并返回控制权给应用程序。以下是acks配置的几种常见取值及其含义：

1. acks=0：

   • 含义：生产者在消息发送到Broker后，不等待任何确认就认为消息发送成功，立即返回。
   • 优点：提供最低的延迟，适用于对消息可靠性要求不高但对发送速度要求极高的场景。
   • 缺点：消息可能在 Broker 尚未接收到或尚未持久化到磁盘时就丢失。这是最不可靠的配置选项。

2. acks=1（默认值）：

   • 含义：生产者在消息被Leader副本接收到并写入其本地日志后，就认为消息发送成功。这意味着至少有一个Broker节点存储了消息。
   • 优点：在消息可靠性与发送延迟之间取得平衡，相比于acks=0，提供了更好的消息持久性。
   • 缺点：如果Leader副本在消息写入后、副本复制到其他节点前发生故障，且该分区没有其他ISR（In-Sync Replicas，同步副本集）副本，消息可能会丢失。

3. acks=all（或acks=-1）：

   • 含义：生产者在消息被Leader副本接收到，并且被所有ISR副本（至少达到min.insync.replicas配置的副本数）都复制确认后，才认为消息发送成功。这是最可靠的配置选项。
   • 优点：提供最高的消息可靠性，即使Leader副本发生故障，只要还有ISR副本存活，消息就不会丢失。
   • 缺点：增加了消息发送的延迟，因为需要等待所有ISR副本确认。在副本数量较多或网络延迟较大的情况下，这种延迟可能较为明显。

示例代码：

在Java生产者中配置acks参数，可以在创建Properties对象时设置：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", StringSerializer.class.getName());
props.put("value.serializer", StringSerializer.class.getName());
props.put("acks", "all"); // 设置acks为all，要求所有ISR副本确认消息

Producer<String, String> producer = new KafkaProducer<>(props);
1
2
3
4
5
6
7

选择合适的acks配置：

选择acks配置时，需要权衡消息的可靠性、延迟和吞吐量。通常遵循以下原则：

• 对于对消息丢失零容忍的业务场景，如金融交易、审计日志等，应选择acks=all，确保消息在任何单点故障下都不会丢失。

• 对于对延迟敏感但可以接受一定消息丢失概率的场景，如实时分析、监控数据等，可以选择acks=1。

• 对于对发送速度要求极高，且可以容忍大量消息丢失的场景（这类场景相对较少），可以选择acks=0。

在实际应用中，可能需要根据业务需求、系统架构、网络状况等因素综合评估，选择最适合的acks配置。同时，还可以结合其他生产者配置（如重试策略、消息批次等）和消费者配置（如消费位移管理、消息处理保证等），共同构建健壮、高效的消息传递系统。