說明
檢視當前伺服器中的所有topic
bin/kafka-topics.sh --zookeeper localhost-102:2181 --list
建立topicbin/kafka-topics.sh --zookeeper localhost-102:2181 \
--create --topic atguigu --replication-factor 3 --partitions 2
選項說明:
--topic 定義topic名
--partitions 定義分割槽數
--replication-factor 定義副本數
刪除topicbin/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...