Kafka 主題命令列操作
阿新 • • 發佈:2022-03-23
檢視操作主題命令引數
bin/kafka-topics.sh
引數 | 描述 |
--bootstrap-server | 連線的 Kafka Broker 主機名稱和埠號。 |
--topic | 操作的 topic 名稱。 |
-create | 建立主題。 |
-delete | 刪除主題。 |
--alter | 修改主題。 |
--list | 檢視所有主題。 |
--describe | 檢視主題詳細描述。 |
--partitions | 設定分割槽數。 |
--replication-factor | 設定分割槽副本。 |
--config | 更新系統預設的配置。 |
1、檢視當前伺服器中的所有 topic
bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --list
2、建立 first topic
bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --create --partitions 1 --replication-factor 3 --topic first
選項說明: --topic 定義 topic 名
--replication-factor 定義副本數
--partitions 定義分割槽數
3、檢視 first 主題的詳情
bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --describe --topic first
4、修改分割槽數(注意:分割槽數只能增加,不能減少)
bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --alter --topic first --partitions 3
5、刪除 topic
bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --delete --topic first