1. 程式人生 > 其它 >Kafka 主題命令列操作

Kafka 主題命令列操作

 

檢視操作主題命令引數

 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