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

  • Z时代
  • 2024-01-10
  • 分类：问答

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

回答：

增加reconnect.backoff.ms属性（请参阅Kafka

docs）。

默认值只有50毫秒。

以上是 Spring-Boot和Kafka：如何处理不可用的经纪人？ 的全部内容， 来源链接： utcz.com/qa/401812.html

回到顶部