kafka之常用命令
阿新 • • 發佈：2018-12-11
kafka常用命令包括建立topic,檢視topic列表等。
| 功能 | 命令 | 備註 |
|---|---|---|
| 建立topic | kafka_home/bin/kafka-topics.sh --create -zookeeper node1:2181 --topic test --replication-factor 1 --partitions 1 | zookeeper地址檢視kafka_home/config/server.properties的zookeeper.connect引數 |
| 檢視Topic列表 | kafka_home/bin/kafka-topics.sh --list -zookeeper node1:2181 | |
| 消費Topic訊息 | kafka_home/bin/kafka-console-consumer.sh --zookeeper node1:2181 --topic test --from-beginning | from-beginning從當前topic中offset有效最小值開始讀取 |
| 生產topic訊息 | kafka_home/bin/kafka-console-producer.sh --broker-list node6:9981 --topic test | kafka使用的broker-list地址檢視kafka_home/config/server.properties的advertised.listeners引數 |
| 檢視offset的有效最小值 | kafka_home/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list node6:9981 -topic test–time -2 | kafka中可設定log的過期時間，到了過期時間，便會刪除，因此最小的offset不是為0，是會持續變化 |
| 檢視offset的有效最大值 | kafka_home/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list node6:9981 -topic test–time -1 | |
| 檢視每個partition的消費效能 | kafka_home/bin/kafka-consumer-perf-test.sh --broker-list node6:9981 --topic test --group test --messages 100000 --show-detailed-stats | 主要看每個partition的消費效能是否正常 |
| 檢視topic的offset,logsize和lag | kafka_home/bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group test --topic test –zookeeper node1:2181 | 檢視在當前groupid下，topic的使用情況 |