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

成都創(chuàng)新互聯(lián)是一家網(wǎng)站設(shè)計(jì)公司，集創(chuàng)意、互聯(lián)網(wǎng)應(yīng)用、軟件技術(shù)為一體的創(chuàng)意網(wǎng)站建設(shè)服務(wù)商，主營(yíng)產(chǎn)品：成都響應(yīng)式網(wǎng)站建設(shè)公司、高端網(wǎng)站設(shè)計(jì)、成都營(yíng)銷網(wǎng)站建設(shè)。我們專注企業(yè)品牌在網(wǎng)站中的整體樹立，網(wǎng)絡(luò)互動(dòng)的體驗(yàn)，以及在手機(jī)等移動(dòng)端的優(yōu)質(zhì)呈現(xiàn)。成都網(wǎng)站建設(shè)、做網(wǎng)站、移動(dòng)互聯(lián)產(chǎn)品、網(wǎng)絡(luò)運(yùn)營(yíng)、VI設(shè)計(jì)、云產(chǎn)品.運(yùn)維為核心業(yè)務(wù)。為用戶提供一站式解決方案，我們深知市場(chǎng)的競(jìng)爭(zhēng)激烈，認(rèn)真對(duì)待每位客戶，為客戶提供賞析悅目的作品，網(wǎng)站的價(jià)值服務(wù)。

  ./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所有主題詳細(xì)信息

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

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)建一個(gè)叫test的話題，有兩個(gè)分區(qū)，每個(gè)分區(qū)3個(gè)副本

6 測(cè)試kafka發(fā)送和接收消息（啟動(dòng)兩個(gè)終端）

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

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

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

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

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

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

7 查看某個(gè)topic對(duì)應(yīng)的消息數(shù)量

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

8 顯示所有消費(fèi)者

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

9 獲取正在消費(fèi)的topic（console-consumer-63307）的group的offset

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

看完上述內(nèi)容是否對(duì)您有幫助呢？如果還想對(duì)相關(guān)知識(shí)有進(jìn)一步的了解或閱讀更多相關(guān)文章，請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝您對(duì)創(chuàng)新互聯(lián)的支持。

新聞標(biāo)題：kafka常用命令有哪些呢
本文地址：http://jinyejixie.com/article0/peoioo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供軟件開發(fā)、網(wǎng)站內(nèi)鏈、網(wǎng)站排名、網(wǎng)站制作、靜態(tài)網(wǎng)站、虛擬主機(jī)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)