夏天

通过判断对应topic的每个分区的副本是否都在，命令行的形式是：

## 查询集群描述
bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181

## 查询集群描述（新）
bin/kafka-topics.sh --bootstrap-server localhost:9092 --topic foo --describe

参考来自：kafka命令大全

感谢您的指点

理论上，kafka是一直要可用的，所以发消息前，是不需要关心kafka集群是否可用。
另外，如果kafka集群真的不可用了，发送消息的时候也自然会报错了。
所以我不希望你过度复杂。

最后，如果你想查通过程序看kafka的状态，参考：https://www.orchome.com/9994

谢谢，我去试试

二进制吧 最简单不用开包压包