如何确认kafka集群状态是否正常？

夏天 发表于: 2021-01-04   最后更新时间: 2021-01-04  

如何确认kafka集群状态是否正常？

问题说明：

  1. 程序在向 kafka 集群发送数据之前，需要检测 kafka 集群状态，若集群正常，则开始发送数据；否则，不发送数据，处理问题。请问该怎么判断 kafka 集群状态呢？

  2. 我找到上述问题的一个解决方案，是查看 ZooKeeper 上的 kafka节点的状态。但是我不确定该方法是否真的能说明问题，即若 ZooKeeper 上显示kafka 节点异常，能否直接断定该kakfa节点真的有问题呢？

环境：

  1. kafka 2.3
  2. jdk 1.8
  3. ZooKeeper 3.5


您需要解锁本帖隐藏内容请： 点击这里
本帖隐藏的内容




上一条: kafka消费群组出现Consumer group 'opentsdb_AQJC1' has no active members状态
下一条: kafka 2.5.1 consumer支持幂等吗


  • 半兽人 14天前

    理论上，kafka是一直要可用的，所以发消息前，是不需要关心kafka集群是否可用。
    另外，如果kafka集群真的不可用了，发送消息的时候也自然会报错了。
    所以我不希望你过度复杂。
    最后，如果你想查看kafka的状态，参考：https://www.orchome.com/9994