kafka命令筆記

2021-10-17 14:08:32 字數 2349 閱讀 5871

1.啟動kafka`

in/kafka-server-


start


.sh .


./config/server.properties
2.建立topic

–partitions 指定分割槽數，–replication-factor 指定備份數

bin/kafka-topics.sh --create --topic test-topic


--replication-factor 1 --partitions 1 --zookeeper localhost:2181
3.增加topic的partition數

bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic test-topic


--partitions 5
4.刪除topic（//）

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


--delete
5.檢視 topic 指定分割槽 offset 的最大值或最小值 ，time 為 -1 時表示最大值，為 -2 時表示最小值：

bin/kafka-run-


class


.sh kafka.tools.getoffsetshell --topic test-topic


--time -1 --broker-list 127.0.0.1:9092 --partitions 0
6.檢視topic列表

bin/kafka-topics.sh --list --zookeeper localhost:2181
7.檢視topic詳情

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


--describe
8.啟動生產者

bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test-topic
9.啟動消費者檢視訊息

bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test-topic
--


from


-beginning  #從頭開始檢視訊息


--offset latest --partition 0 #從尾開始（需指定分割槽）


--max-messages 10  #最近10條訊息


| grep message #匹配訊息
10.檢視最大offset --time -1 最小offset --time -2

bin/kafka-run-


class


.sh kafka.tools.getoffsetshell --broker-list  127.0.0.1:9092  --topic test-topic


--time -1
11.檢視group 列表

bin/kafka-consumer-groups.sh --list  --bootstrap-server  127.0.0.1:9092
12.檢視group狀態

bin/kafka-consumer-groups.sh  --bootstrap-server  127.0.0.1:9092  --


group


test-group


--describe
13.檢視某一時間的offset

bin/kafka-run-


class


.sh kafka.tools.getoffsetshell --broker-list 127.0.0.1:9092  --topic test-topic


--time  1622995200000
14.指定offset點位開始消費（需指定partition）

bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092  --topic test-topic


--offset 81568  --partition 0

kafka常用命令筆記

0.檢視有哪些主題 kafka topics.sh list zookeeper 192.168.0.201 12181 1.檢視topic的詳細資訊 kafka topics.sh zookeeper 127.0.0.1 2181 describe topic testkj1 2 為topic增加...

kafka啟動命令 Kafka入門

kafka是乙個高效能分布式訊息系統，今天就簡單介紹下基礎入門吧。tar xzf kafka 2.12 2.2.0.tgz cd kafka 2.12 2.2.0二 啟動伺服器kafka使用zookeeper，所以我們要先啟動zookeeper，可以使用安裝檔案裡面的啟動命令啟動乙個單節點的zook...

kafka命令 Kafka命令列簡單使用

建立主題 kafka topics.sh create zookeeper 172.16.48.163 2181 kafka replication factor 2 partitions 1 topic test9999 replication factor 該主題每個分割槽的副本數，不能大於br...