Kafka 命令列操作

2021-10-02 00:10:45 字數 1294 閱讀 8821

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

bin/kafka-topics.sh --zookeeper localhost:2181 --list
2. 建立 topic

bin/kafka-topics.sh --zookeeper localhost:2181 --create --replication-factor 3 --partitions 1 -topic first
選項說明：

topic 定義 topic 名

replication-factor 定義副本數

partitions 定義分割槽數

3. 刪除 topic

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic first
需要 server.properties 中設定 delete.topic.enable=true 否則只是標記刪除

4. 傳送訊息

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


>hello world
5. 消費訊息

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic first
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic first
–from-beginning：會把主題中以往所有的資料都讀取出來

6. 檢視某個 topic 的詳情

bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic first
7. 修改分割槽數

bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic first --partitions 6

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.檢視當前伺服器中的所有topicbin kafka topics.sh zookeeper bigdata13 2181 list2.建立topicbin kafka topics.sh zookeeper bigdata13 2181 create replication factor 3 p...

kafka 命令列操作

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