Kafka常用命令匯總:
1犯眠、列出集群里的所有主題甫菠。
kafka-topics.sh --zookeeper localhost:2181 --list
2徘跪、 創(chuàng)建一個叫作topic_01的主題,主題包含8分區(qū),每個分區(qū)擁有兩個副本模软。
kafka-topics.sh --zookeeper localhost:2181 --create --topic topic_01 --replication-factor 3 --partitions 3
3雁仲、列出集群里所有主題的詳細信息疗我。
kafka-topics.sh --zookeeper localhost:2181 --describe
4咆畏、列出集群里特定主題的詳細信息。
kafka-topics.sh --zookeeper localhost:2181 --describe? --topic topic_01
5吴裤、刪除topic_01的主題旧找。
kafka-topics.sh --zookeeper localhost:2181 --delete? --topic topic_01
6、列出舊版本的所有消費者群組麦牺。
kafka-consumer-groups.sh --zookeeper localhost:2181 --list
7钮蛛、列出新版本的所有消費者群組鞭缭。
kafka-consumer-groups.sh --new-consumer --bootstrap-server 172.21.50.162:9092 --list
8、獲取舊版本消費者群組testgroup的詳細信息愿卒。
kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group testgroup
9缚去、獲取新版本消費者群組testgroup的詳細信息。
kafka-consumer-groups.sh --new-consumer --bootstrap-server 172.21.50.162:9092 --describe --group testgroup
10琼开、查看某一個topic對應(yīng)的消息數(shù)量易结。
kafka-run-class.sh? kafka.tools.GetOffsetShell --broker-list 172.21.50.162:9092 --topic topic_01 --time -1
11、查看log日志片段的內(nèi)容,顯示查看日志的內(nèi)容柜候。
kafka-run-class.sh kafka.tools.DumpLogSegments --files 00000000000000000000.log --print-data-log
12搞动、控制臺生產(chǎn)者:向主題 my-topic 生成兩個消息。
kafka-console-producer.sh --broker-list localhost:9092 --topic topic_01
13渣刷、控制臺消費者:從主題 my-topic 獲取消息鹦肿。
kafka-console-consumer.sh --zookeeper localhost:2181? --topic topic_01 --from-beginning
kafka-console-consumer.sh --new-consumer --bootstrap-server 172.21.50.162:9092? --topic topic_01 --from-beginning
