java - Spring-Boot 和 Kafka : How to handle broker not available?

Question

当 spring-boot 应用程序正在运行时，如果我完全关闭代理(kafka 和 zookeeper)，我会在控制台中无限期地看到此警告。

[org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] WARN o.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=ResponseReceiveConsumerGroup] Connection to node 2147483647 could not be established. Broker may not be available.

在 Spring Boot 中有没有一种方法可以优雅地处理这个问题，而不是在控制台上无限记录？

Answer 1

增加 reconnect.backoff.ms 属性(参见 Kafka docs)。

默认只有 50ms。