kafka节点故障后Kafka生产者/消费者重新连接

Question

我有一些 kafka 消费者和生产者（Spring boot），当它们连接的 Kafka 节点出现故障（例如失败）时，它们会记录以下内容：

2019-03-15 11:02:53.278 警告 1 --- [tainer#1-23-C-1] org.apache.kafka.clients.NetworkClient ：[消费者 clientId=consumer-29，groupId=OperationsConsumer] 连接时出错到节点 kafka-0.kafka-headless.test.svc.cluster.local:9092 (id: 1001 机架: null)

java.io.IOException：无法解析地址：kafka-0.kafka-headless.test.svc.cluster.local:9092

但是，即使我将节点显式设置到属性中，它们也不会尝试重新连接到有效的 kafka 节点bootstrap.servers。

在消费者连接的 kafka 节点发生故障后，如何让消费者重新连接到有效的 kafka 节点？

Answer 1

检查您的重新连接属性：

\n\n

\n
• 重新连接.backoff.ms
\n
• 重新连接.backoff.max.ms
\n

\n\n

\xe2\x80\xa6如Kafka 文档中提到的

\n\n

在评估重新连接是否成功之前，您是否让它们过去了？

\n\n

除了下一个节点之外，至少还需要一个节点bootstrap.servers有机会建立新连接。另请检查所有节点是否通过相同的 Zookeeper 进行通信，并且 Kafka 设置本身是否秩序良好。

\n