Kafka命令列操作

2021-10-06 21:12:39 字數 962 閱讀 2157

1.檢視當前伺服器中的所有topic

bin/kafka-topics.sh --zookeeper bigdata13:2181 --list
2.建立topic
bin/kafka-topics.sh --zookeeper bigdata13:2181 --create --replication-factor 3 --partitions 1 --topic first
選項說明:

--topic 定義topic名

--replication-factor 定義副本數

--partitions 定義分割槽數

3.刪除topic
bin/kafka-topics.sh --zookeeper bigdata11:2181 --delete --topic first
需要server.properties中設定delete.topic.enable=true否則只是標記刪除或者直接重啟。

4.傳送訊息

bin/kafka-console-producer.sh --broker-list bigdata11:9092 --topic first

>hello world

>itstar itstar

5.消費訊息
bin/kafka-console-consumer.sh --zookeeper bigdata11:2181 --from-beginning --topic first
–from-beginning:會把first主題中以往所有的資料都讀取出來。根據業務場景選擇是否增加該配置。

6.檢視某個topic的詳情

bin/kafka-topics.sh --zookeeper bigdata11:2181 --describe --topic first

Kafka命令列操作

1 檢視當前伺服器中的所有topic atguigu hadoop102 kafka bin kafka topics.sh zookeeper hadoop102 2181 list2 建立topic atguigu hadoop102 kafka bin kafka topics.sh zook...

Kafka 命令列操作

1.檢視當前伺服器中的所有 topic bin kafka topics.sh zookeeper localhost 2181 list2.建立 topic bin kafka topics.sh zookeeper localhost 2181 create replication factor...

kafka 命令列操作

hadoop hadoop201 kafka 2.11 0.11 0.0 bin kafka topics.sh list zookeeper hadoop201 2181 沒有主題時,什麼也不會輸出建立乙個topic,有2個分割槽2個副本 選項說明 topic 定義topic名 replicati...