（本文中 zookeeper:2181 和kafka 9092 的 的zookeeper 和kafka 對(duì)應(yīng)的是你對(duì)應(yīng)服務(wù)的IP地址，
本文的kafka的版本是0.10.0.0）
首先進(jìn)到kafka 的容器中 找到bin目錄，我們可以看到有很多腳本文件
kafka 腳本
創(chuàng)建一個(gè)主題
sh kafka-topics.sh --create --zookeeper zookeeper :2181 --replication-factor 1 --partitions 1 --topic test
查看主題
sh kafka-topics.sh --list --zookeeper zookeeper :2181
打開生產(chǎn)者界面
sh kafka-console-producer.sh --broker-list kafka:9092 --topic test
打開消費(fèi)者界面
消費(fèi)者記錄在zookeeper
sh kafka-console-consumer.sh --zookeeper zookeeper:2181 --topic test --from-beginning
消費(fèi)者記錄在kafka
kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic
test2 --from-beginning --new-consumer
查詢消息消費(fèi)情況
如果消費(fèi)者記錄在kafka 可以這樣查看消費(fèi)者的分組情況
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --list --new-consumer
執(zhí)行之后可以看到分組的groupId 例如 console-consumer-20764
查看消費(fèi)情況
kafka-consumer-groups.sh --new-consumer --bootstrap-server kafka:9092 --group console-consumer-20764 --describe
如果消費(fèi)記錄在zookeeper 可以這樣可查看分組
kafka-consumer-groups.sh --zookeeper zookeeper:2181 --list
執(zhí)行之后可以看到分組的gruopId 例如 console-consumer-25338
查看消費(fèi)情況
kafka-consumer-groups.sh --zookeeper zookeeper:2181 --group console-consumer-25338 --describe
刪除主題
sh kafka-topics.sh --delete --zookeeper zookeeper:2181 --topic test
這個(gè)命令只能標(biāo)記這個(gè)topic 被刪除行嗤，通過查看主題的命令還可以看到該主題悼泌。
查看kafka 消息文件所在目錄 /kafka/config/server.properties
找到 log.dirs
我的文件對(duì)于的地址是 log.dirs=/tmp/kafka-logs
到這個(gè)目錄下可以看到kafka 存在磁盤的文件
