apache-kafka - 测试 Kafka HA 并获取 NetworkException : The server disconnected before a response was received

Question

运行 Confluent Kafka 4.1.1 社区。

我有...

• 最小同步副本数 = 2
• 主题:1 个分区，副本数 3
• 共有 3 个经纪人。
• 生产者设置为 acks = -1
• 所有其他制作人设置均为默认设置。

我启动我的应用程序，当它开始向 Kafka 写入记录时 我故意关闭其中一个代理，我立即得到:org.apache.kafka.common.errors.NetworkException : 服务器在收到响应之前断开连接。

基于上面的设置。生产者 write() 不应该成功并且不抛出错误吗？

澄清

• 我故意杀了一个经纪人
• 这似乎只有在 leader broker 被杀时才会发生？

Answer 1

没有看到完整的配置。和日志消息，很难说，仍然..

在 Kafka 中，所有写入都经过领导分区。在您的设置中，在 3 个经纪人中，您杀死了 1 个。因此应该可以成功写入其余 2 个并获得确认。但如果被杀死的代理是领导节点，则可能导致异常。

来自文档:

acks=all This means the leader will wait for the full set of in-sync replicas to acknowledge the record. This guarantees that the record will not be lost as long as at least one in-sync replica remains alive. This is the strongest available guarantee.

在任何情况下，您都可以将重试次数设置为大于 0 的值并查看行为 - 应该选出新的领导者并且您的写入最终应该成功