apache-kafka - 带有 acks = all 的异步模式

Question

我看到 acks all 的不同行为。从文档中，

acks=all This means the leader will wait for the full set of in-syncreplicas to acknowledge the record. This guarantees that the recordwill not be lost as long as at least one in-sync replica remainsalive. This is the strongest available guarantee. This is equivalentto the acks=-1 setting.

我有一个 3 个代理设置和一个复制因子为 3 的主题。我对上述声明的理解是，如果任何代理宕机，领导者将等待(因为它*将等待 ISR 确认 * 记录。但是，为了令我惊讶的是，事实并非如此，消息是由消费者生产和消费的。
难道，在这种情况下，它不兑现？

Answer 1

acks = all 与 min.insync.replicas 代理参数相关，默认为 1；这就是为什么您看到您的生产者发送没有问题并且消费者也在消费的原因。
在您的情况下，有 3 个代理，如果您希望生产者只能在所有代理都运行时发送，您还必须设置 min.insync.replicas=3。