在Spring Kafka中检测到Broker断开连接 [英] Detecting that the broker is disconnected in Spring Kafka

问题描述

我正在尝试为我的卡夫卡消费者写一份健康检查。当应用程序启动并运行时，我关闭了Kafka，我看到了很多

 Connection to node 1001 (/127.0.0.1:9092) could not be established. Broker may not be available.

在日志中，但没有ApplicationEvent、调用了错误处理程序，没有任何内容。似乎无法通过监听程序调用来获取NetworkClient状态。我的理解是，过去在代理断开连接时会生成一个ApplicationEvent。我错过了什么吗？

推荐答案

遗憾的是，kafka客户端没有向调用者提供代理已关闭的指示。

这些是唯一可用的事件：https://docs.spring.io/spring-kafka/docs/current/reference/html/#events

您可以启用ListenerContainerIdleEvent%s，但无法判断容器只是空闲还是未连接。

但是，您可以使用事件中的Consumer进行一些非破坏性调用，例如获取指定主题的endOffsets()。如果调用超时，您将得到一个异常。有关示例，请参阅this answer。

这篇关于在Spring Kafka中检测到Broker断开连接的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！