查看所有Topic信息
bin/kafka-topics.sh --zookeeper localhost:2181 --list
產(chǎn)看單個(gè)Topic信息
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic xxx
查看所有正在連接的Consumer信息
bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --list
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
查看單個(gè)Consumer信息
bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group BrowseConsumer
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group BrowseConsumer
重頭開始消費(fèi)某個(gè)Topic
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic xxx
bin/kafka-console-consumer.sh --new-consumer --bootstrap-server localhost:9092 --from-beginning --topic xxx
查看某個(gè)Topic所在的節(jié)點(diǎn)信息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic xxx
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
