kafka指令行操作

1）檢視目前伺服器中的所有topic

[[email protected] kafka]$ bin/kafka-topics.sh --zookeeper
 hadoop102:2181 --list
           

2）建立topic

[[email protected] kafka]$ bin/kafka-topics.sh --zookeeper
 hadoop102:2181 --create --replication-factor 3 --partitions 1 
 --topic first
           

選項說明：

–topic 定義topic名

–replication-factor 定義副本數

–partitions 定義分區數

3）删除topic

[[email protected] kafka]$ bin/kafka-topics.sh --zookeeper
 hadoop102:2181 --delete --topic first
           

4）發送消息

[[email protected] kafka]$ bin/kafka-console-producer.sh 
--broker-list hadoop102:9092 --topic first
           

hello world

atguigu atguigu

5）消費消息

[[email protected] kafka]$ bin/kafka-console-consumer.sh \
--bootstrap-server hadoop102:9092 --topic first
           

[[email protected] kafka]$ bin/kafka-console-consumer.sh \
--bootstrap-server hadoop102:9092 --from-beginning --topic first
           

–from-beginning：會把主題中現有的所有的資料都讀取出來。

6）檢視某個Topic的詳情

[[email protected] kafka]$ bin/kafka-topics.sh 
--zookeeper hadoop102:2181 --describe –
-topic first
           

7）修改分區數

[[email protected] kafka]$ bin/kafka-topics.sh 
--zookeeper hadoop102:2181 --alter –-
topic first --partitions 6