我需要一个简单的健康检查 Apache Kafka . 我不想要像这样大而复杂的东西 Yahoo Kafka Manager ，基本上我想检查一个主题是否健康，一个消费者是否健康。
我的第一个想法是创建一个单独的 heart-beat 主题并定期向它发送和读取消息，以检查可用性和延迟。
第二个想法是从 Apache Zookeeper . 我可以从zk获得所有代理、分区、主题等，但是我不知道zk是否可以提供类似故障检测的信息。
正如我所说，我需要一些简单的东西，我可以用在我的应用程序健康检查。