反正已经挂了
直接格式化这块盘,启动时会自动恢复的
这个错误一般是server.properties
中kafka网络配置不对,比如你配置的是:
listeners=PLAINTEXT://你的内网ip:9092
则命令就不得使用localhost了,使用对应的ip,如:
./kafka-consumer-groups.sh --bootstrap-server 你的内网ip:9092 --list
另外,你没提供相应的kafka版本,提供给你不同版本的消费者列表查询:
## 消费者列表查询(存储在zk中的)
bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --list
## 消费者列表查询(支持0.9版本+)
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
## 消费者列表查询(支持0.10版本+)
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
命令来自:kafka命令大全