kafka命令筆記

1.啟動kafka`

in/kafka-server-

start
.sh .
./config/server.properties

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

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

--replication-factor 1 --partitions 1 --zookeeper localhost:2181

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

--partitions 5

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

--delete

bin/kafka-run-

class
.sh kafka.tools.getoffsetshell --topic test-topic
--time -1 --broker-list 127.0.0.1:9092 --partitions 0

bin/kafka-topics.sh --list --zookeeper localhost:2181

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

--describe

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

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 #匹配訊息

bin/kafka-run-

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

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

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

group
test-group
--describe

bin/kafka-run-

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

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...