2 kafka 命令列操作

2021-10-07 14:37:34 字數 1099 閱讀 6724

說明

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

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

--create --topic atguigu --replication-factor 3 --partitions 2

選項說明:

--topic 定義topic名

--partitions 定義分割槽數

--replication-factor 定義副本數

刪除topic
bin/kafka-topics.sh --zookeeper localhost-102:2181 \

--delete --topic atguigu

傳送訊息
bin/kafka-console-producer.sh \

--broker-list localhost-102:9092 --topic atguigu

# 敲入鍵值對即可

>hello world

>atguigu atguigu

消費訊息
bin/kafka-console-consumer.sh \

--bootstrap-server localhost-102:9092 --from-beginning --topic atguigu

選項說明:

--from-beginning:會把主題中以往所有的資料都讀取出來

檢視某個topic的詳情
bin/kafka-topics.sh --zookeeper localhost-102:2181 \

--describe --topic atguigu

修改分割槽數
bin/kafka-topics.sh --zookeeper localhost-102:2181 \

--alter --topic atguigu --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.檢視當前伺服器中的所有 topic bin kafka topics.sh zookeeper localhost 2181 list2.建立 topic bin kafka topics.sh zookeeper localhost 2181 create replication factor...

Kafka命令列操作

1.檢視當前伺服器中的所有topicbin kafka topics.sh zookeeper bigdata13 2181 list2.建立topicbin kafka topics.sh zookeeper bigdata13 2181 create replication factor 3 p...