如何确认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支持幂等吗

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