Spring-Boot和Kafka：如何处理不可用的经纪人？

Question

在spring-boot应用程序运行时，如果我完全关闭了代理（kafka和zookeeper），我会在控制台中看到此警告时间很长。

[org.springframework.kafka.KafkaListenerEndpointContainer＃0-0-C-1]警告o.apache.kafka.clients.NetworkClient-[Consumer clientId = consumer-1，groupId = ResponseReceiveConsumerGroup]无法建立与节点2147483647的连接。经纪人可能不可用。

Spring Boot中是否有一种方法可以优雅地处理此问题，而不是在控制台上无限处理日志？

Answer 1

增加reconnect.backoff.ms属性（参见Kafka 文档）。

默认仅为 50 毫秒。