Kafka經常使用指令

工做中常常會用到的指令

 

 1 # 查詢topic爲test的partition數量 
 2 ./kafka-topics.sh --zookeeper localhost:2181/kafka --topic test --describe
 3 
 4 
 5 # 查看kafka上全部的topic 
 6 ./kafka-topics.sh --zookeeper localhost:2181/kafka --list 
 7 
 8 
 9 # 發送消息 
10 ./kafka-console-producer.sh --broker-list localhost:9092 --topic test 
11 
12 
13 # 收取消息 
14 ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning 
15 
16 
17 # 修改topic爲test的partition數量（只能越修改越大） 
18 ./kafka-topics.sh --zookeeper localhost:2181 --alter --topic test --partitions 8
19 
20 
21 # 建立名爲test的topic
22 ./kafka-topics.sh --create --zookeeper localhost:2181 --topic test --replication-factor 1 --partition 4
23 
24 
25 # 刪除爲test的topic
26 ./kafka-topics.sh --delete --zookeeper localhost:2181 --topic test 
27 
28 
29 # 查看全部的group
30 ./kafka-run-class.sh kafka.admin.ConsumerGroupCommand --zookeeper localhost:2181 --list
31 
32 
33 # 查看數據是否消費完成 
34 ./kafka-run-class.sh kafka.admin.ConsumerGroupCommand --zookeeper localhost:2181 --describe --group testGroup