java - Kafka Java客户端处理连接，服务器问题

Question

我正在使用 Kafka Java 客户端，有时我们在 Kafka Server 中有一些停机时间。我们需要向监控系统发送 Kafka 服务器不可用的警报。

从 Java 客户端对 Kafka 服务器进行健康检查的最佳方法是什么？

标签： javaapache-kafkakafka-consumer-api

Answer 1

如果您的主要目标是检查 Kafka 代理集群是否启动，您可以通过以下方式检查

1. Kafka 代理端口可用
2. 监视 Zookeeper 节点以供代理检查是否有任何子节点可用。