Kafka有哪些常用命令

本篇內(nèi)容主要講解“Kafka有哪些常用命令”，感興趣的朋友不妨來(lái)看看。本文介紹的方法操作簡(jiǎn)單快捷，實(shí)用性強(qiáng)。下面就讓小編來(lái)帶大家學(xué)習(xí)“Kafka有哪些常用命令”吧!

1、開(kāi)啟zookeeper（在安裝目錄下使用命令）

Linux：bin/zkServer.sh start

windows:bin\zkServer.cmd

2、啟動(dòng)kafka（安裝目錄下使用命令）

Linux：bin/kafka-server-start.sh start config/server.properties

windows:bin\windows\kafka-server-start.bat config\server.properties

3、查看topic名稱列表

Linux：bin/kafka-topics.sh -list --zookeeper 172.16.0.99:2181,172.16.0.218:2181

windows:bin\windows\kafka-topics.bat -list --zookeeper 172.16.0.99:2181,172.16.0.218:2181

4、查看topic詳情

Linux：bin/kafka-topics.sh -zookeeper localhost:2181 --topic test --describe

windows：bin\windows\kafka-topics.bat --zookeeper localhost:2181 --topic test --describe

5、刪除topic

Linux：bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic "test"

windows:bin\windows\kafka-topics.bat --zookeeper localhost:2181 --delete --topic "test"

注意：集群中一臺(tái)機(jī)器刪除了topic，其他機(jī)器同步刪除相同topic

6、創(chuàng)建topic

Linux：bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

windows:bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

注意：

replication-factor:副本個(gè)數(shù)，一般為小于等于Broker個(gè)數(shù)。

partitions：分區(qū)個(gè)數(shù)。如果副本個(gè)數(shù)為1，分區(qū)為4，則4個(gè)分區(qū)會(huì)均勻的分布在各個(gè)Broker上。如果Broker為2，副本為2，分區(qū)為4，則每個(gè)Broker上面都有4個(gè)分區(qū)。

7、創(chuàng)建Consumer

Linux：bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

windows：bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test --form-beginning

注意：form beginning表示從頭拉取。

8、創(chuàng)建Producer

Linux：bin/kafka-console-producer.sh --broker-list 172.16.0.99:9020,172.16.0.218:9020 --topic test

windows：bin\windows\kafka-console-producer.bat --broker-list 172.16.0.99:9092,172.16.0.218:9080 --topic test

注意：此處是kafka的端口，而且在集群里如果此處填localhost，會(huì)報(bào)一個(gè)連接錯(cuò)誤，猜想應(yīng)該是消息沒(méi)有到達(dá)集群，因此此處將集群的ip都填上。

9、查詢topic所有分區(qū)的offset值

Linux：bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 10.162.160.115:9092 --topic s1mmetest --time -1

10、查詢kafka集群當(dāng)前topic所有分區(qū)中的消息數(shù)目

Linux：bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 132.232.78.175:9092 --topic s1mmetest --time -2

參考：https://www.2cto.com/kf/201804/739331.html

到此，相信大家對(duì)“Kafka有哪些常用命令”有了更深的了解，不妨來(lái)實(shí)際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！