在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中是否有一种方法可以优雅地处理此问题,而不是在控制台上无限处理日志?
增加reconnect.backoff.ms属性(请参阅Kafka docs)。
reconnect.backoff.ms
默认值只有50毫秒。