SpringBoot和kafka:如何处理代理不可用?

ttisahbt  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(345)

当springboot应用程序运行时,如果我完全关闭代理(kafka和zookeeper),我会在控制台中看到这个警告无限长的时间。
[org.springframework.kafka.kafkalistenerendpointcontainer#0-0-c-1]警告o.apache.kafka.clients.networkclient-[consumer clientid=consumer-1,groupid=responsereceiveconsumergroup]无法建立到节点2147483647的连接。代理可能不可用。
在springboot中有没有一种方法可以优雅地处理这个问题,而不是在控制台上处理无限的日志?

bf1o4zei

bf1o4zei1#

增加 reconnect.backoff.ms 财产(见Kafka文件)。
默认值仅为50ms。

相关问题