一尘不染

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

spring-boot

在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中是否有一种方法可以优雅地处理此问题,而不是在控制台上无限处理日志?


阅读 397

收藏
2020-05-30

共1个答案

一尘不染

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

默认值只有50毫秒。

2020-05-30