apache-kafka - 除了状态之外，将 kafka-streams 的健康/活跃度与连接计数挂钩吗？

Question

我已经遵循Spring Actuator + Kafka Streams - Add kafka stream status to health check endpoint中给出的建议，并将我的 liveness-probe（健康检查）连接到streams.state().isRunningOrRebalancing.

但是，当我关闭所有 3 台代理机器（从而模拟任何硬件/网络故障）时，我可以看到 kafka-streams 正在发出大量Error connecting to node日志，但状态仍然是RUNNING.

我试图找到另一个迹象，但我发现connection-count指标从 3 下降到 0。当这个指标下降到 0 时，为我的应用程序返回不健康的结果是否有意义（从而导致重新启动和警报） ? 或者有没有更好的方法来检测这种缺乏连接性？

标签： apache-kafkakafka-consumer-apiapache-kafka-streams