
如何确认kafka集群状态是否正常?
问题说明:
程序在向 kafka 集群发送数据之前,需要检测 kafka 集群状态,若集群正常,则开始发送数据;否则,不发送数据,处理问题。请问该怎么判断 kafka 集群状态呢?
我找到上述问题的一个解决方案,是查看 ZooKeeper 上的 kafka节点的状态。但是我不确定该方法是否真的能说明问题,即若 ZooKeeper 上显示kafka 节点异常,能否直接断定该kakfa节点真的有问题呢?
环境:
- kafka 2.3
- jdk 1.8
- ZooKeeper 3.5