Kafka 2.0課程 7 Topics CLI

Topics CLI(Command Line Interface)

在學Topics指令前請先確認以下兩個伺服器皆運作中

啟動zookeeper server:

zookeeper-server-start.bat D:\Kafka2\kafka_2.12–2.4.0\config\zookeeper.properties

啟動kafka server:

kafka-server-start.bat D:\Kafka2\kafka_2.12–2.4.0\config\server.properties

使用kafka topics指令:

kafka-topics --zookeeper 127.0.0.1:2181

原本kafka-topics是指kafka-topics.bat(後面點bat可省略)

並且引用zookeeper及zookeeper的ip&port

(請看zookeeper的啟動cmd,裡面會顯示port)

發現會出現doc

出現doc就代表有錯誤!

打更完整的指令如下:

kafka-topics --zookeeper 127.0.0.1:2181 --topic first_topic --create

還是錯! 提示說少了partitions

還是錯! 提示說少了replication-factor

還是錯! 提示說我們不能指定多過broker的replication-factor數量

終於正常建立了!!

完整建立topic的指令如下:

kafka-topics --zookeeper 127.0.0.1:2181 --topic first_topic --create --partitions 3 --replication-factor 1

接著想確認目前有多少topic的指令如下:

kafka-topics --zookeeper 127.0.0.1:2181 --list

接著想更進一步地確認這個topic內有多少的partiction的指令如下

kafka-topics --zookeeper 127.0.0.1:2181 --topic first_topic --describe

看到有0~2這三個partitions,並且ReplicationFactor為1,並且沒有額外的Configs

上圖中的Leader:0即指broker ID為0

在kafka伺服器的cmd也會看到:

同理隨便建立第二個topic:second_topic

second_topic建立成功

正常刪除secon_topic指令如下:

kafka-topics --zookeeper 127.0.0.1:2181 --topic second_topic --delete

但因為window版本bug，在執行delete指令會導致kafka crash

恢復crash方式是把data/kafka刪除

目前delete這步就跳過

(Linux版沒問題)

參考課程