kafka常用命令有哪些呢

kafka常用命令有哪些呢，很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細講解，有這方面需求的人可以來學習下，希望你能有所收獲。

  ./kafka-topics.sh  --help //幫助文檔

1 ./kafka-topics.sh --list --zookeeper ambari1:2181,ambari2:2181  //查看 kafka主題列表  

2 ./kafka-topics.sh --describe --zookeeper ambari1:2181,ambari2:2181   //查看 kafka所有主題詳細信息

3 ./kafka-topics.sh --describe --zookeeper ambari1:2181,ambari2:2181 --topic test  //查看 kafka某一指定主題的詳細信息

4 ./kafka-topics.sh --delete --zookeeper ambari1:2181,ambari2:2181 --topic  test //刪除某一主題

5 ./kafka-topics.sh --zookeeper ambari1:2181,ambari2:2181 --create --topic test --replication-factor 3 --partitions 2 //創(chuàng)建一個叫test的話題，有兩個分區(qū)，每個分區(qū)3個副本

6 測試kafka發(fā)送和接收消息（啟動兩個終端）

#發(fā)送消息（注意端口號為配置文件里面的端口號）

./kafka-console-producer.sh --broker-list ambari1:9092 --topic test

#消費消息（可能端口號與配置文件保持一致，或與發(fā)送端口保持一致）

./kafka-console-consumer.sh --bootstrap-server ambari1:9092 --topic test --from-beginning   #加了--from-beginning 重頭消費所有的消息

./kafka-console-consumer.sh --bootstrap-server ambari1:9092 --topic test         #不加--from-beginning 從最新的一條消息開始消費

./kafka-console-consumer.sh --bootstrap-server ambari1:9092 --topic test   --group   consumerGroup1  #指定消費者組

7 查看某個topic對應的消息數(shù)量

./kafka-run-class.sh  kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -1

8 顯示所有消費者

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list

9 獲取正在消費的topic（console-consumer-63307）的group的offset

./kafka-consumer-groups.sh --describe --group console-consumer-63307 --bootstrap-server localhost:9092

看完上述內(nèi)容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注億速云行業(yè)資訊頻道，感謝您對億速云的支持。