【发布时间】:2020-10-17 20:35:50
【问题描述】:
我在我的 Kafka 生产者上设置了以下属性:
properties.setProperty(ProducerConfig.ACKS_CONFIG, "all");
当我启动我的应用程序时,我在ProducerConfig values 中看到acks = -1。这是为什么呢?
【问题讨论】:
标签: java apache-kafka kafka-producer-api
我在我的 Kafka 生产者上设置了以下属性:
properties.setProperty(ProducerConfig.ACKS_CONFIG, "all");
当我启动我的应用程序时,我在ProducerConfig values 中看到acks = -1。这是为什么呢?
【问题讨论】:
标签: java apache-kafka kafka-producer-api
对于生产者配置,-1 的 acks 属性等于 all。
Producer config 来自 Kafka 文档:
acks=all 这意味着领导者将等待完整的同步 副本以确认记录。这保证了记录 只要至少保留一个同步副本就不会丢失 活。这是最有力的保证。 这是等价的 到 acks=-1 设置。
【讨论】: