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