這篇文章將為大家詳細講解有關(guān)kafka新版常用命令有哪些，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

創(chuàng)新互聯(lián)公司堅持“要么做到，要么別承諾”的工作理念，服務(wù)領(lǐng)域包括：成都網(wǎng)站建設(shè)、成都做網(wǎng)站、企業(yè)官網(wǎng)、英文網(wǎng)站、手機端網(wǎng)站、網(wǎng)站推廣等服務(wù)，滿足客戶于互聯(lián)網(wǎng)時代的越秀網(wǎng)站設(shè)計、移動媒體設(shè)計的需求，幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴！

1/列出topic的命令為：
kafka-topics.sh --zookeeper 10.211.55.11:2181,10.211.55.12:2181,10.211.55.13:2181/kafkagroup --list
2/刪除topic的命令為：
kafka-topics.sh --delete --zookeeper 10.211.55.11:2181,10.211.55.12:2181,10.211.55.13:2181/kafkagroup --topic topic-majihui
3/創(chuàng)建topic命令如下：
kafka-topics.sh --create --zookeeper 10.211.55.11:2181,10.211.55.12:2181,10.211.55.13:2181/kafkagroup --partitions 30 --replication-factor 3 --topic topic-by-majihui
4/查看topic的詳情 包括 partition和repilce的分配位置
kafka-topics.sh --zookeeper 10.211.55.11:2181,10.211.55.12:2181,10.211.55.13:2181/kafkagroup --describe  --topic topic-by-majihui
5/在其中一個broker上創(chuàng)建一個生產(chǎn)者 終端
kafka-console-producer.sh --topic topic-by-majihui --broker-list kafka01-55-11:9092,kafka02-55-12:9092,kafka03-55-13:9092
接下來需要驗證 驗證消息生產(chǎn)成功命令如下：
kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 10.211.55.11:9092 --topic topic-by-majihui --time -1

6/啟動終端的消費者    //總結(jié)：–from-beginning參數(shù)如果有表示從最開始消費數(shù)據(jù)，舊的和新的數(shù)據(jù)都會被消費，而沒有該參數(shù)表示只會消費新產(chǎn)生的數(shù)據(jù)
kafka-console-consumer.sh --bootstrap-server  kafka01-55-11:9092,kafka02-55-12:9092,kafka03-55-13:9092  --topic topic-by-majihui --from-beginning
//啟動一個新的消費者 讓他屬于某個消費組 new-consumer-majihui
kafka-console-consumer.sh --bootstrap-server 10.211.55.11:9092 --consumer-property group.id=new-consumer-majihui --consumer-property client.id=new-consumer-cl --topic topic-by-majihui
此時去執(zhí)行了列出消費者 就會看到：
[hadoop@kafka03-55-13 ~]$ kafka-consumer-groups.sh --bootstrap-server kafka01-55-11:9092,kafka02-55-12:9092,kafka03-55-13:9092 --list
new-consumer-majihui

7/列出消費組   //查看有哪些消費組在消費消息     問題 如何創(chuàng)建一個消費組？
kafka-consumer-groups.sh --bootstrap-server kafka01-55-11:9092,kafka02-55-12:9092,kafka03-55-13:9092 --list
kafka-consumer-groups.sh --bootstrap-server tencent-kafka01-39-110:9092 --list
8/查看某個消費組的消費進度   消費詳情
kafka-consumer-groups.sh --bootstrap-server kafka01-55-11:9092,kafka02-55-12:9092,kafka03-55-13:9092 --describe --group console-consumer-120
//這個 console-consumer-120 是上面這個查看消費組查出來的
9/查看topic某分區(qū)偏移量最大（?。┲?br/>kafka-run-class.sh kafka.tools.GetOffsetShell --topic topic-by-majihui --time -1 --broker-list kafka01-55-11:9092,kafka02-55-12:9092,kafka03-55-13:9092 --partitions 0
注： time為-1時表示最大值，time為-2時表示最小值
10/查看kafka某分區(qū)日志具體內(nèi)容 index 和 log 文件的具體內(nèi)容查看
kafka-run-class.sh kafka.tools.DumpLogSegments --files /tmp/kafka-logs/firsttopic-0/00000000000000000000.log --print-data-log > 00000000000000000000.txt0
11/kafka-run-class.sh kafka.tools.DumpLogSegments --files /data/kafka/kafka-logs/topic-by-majihui-9/00000000000000000000.index --print-data-log > 00000000000000000000index.txt
12/平衡leader
kafka-preferred-replica-election.sh  --bootstrap-server kafka01-55-11:9092,kafka02-55-12:9092,kafka03-55-13:9092

關(guān)于“kafka新版常用命令有哪些”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，使各位可以學(xué)到更多知識，如果覺得文章不錯，請把它分享出去讓更多的人看到。