一.準備工具

• 已編譯好的Kafka-manager安裝壓縮包(下載)

二.操作步驟

    1.解壓縮安裝包,最好跟之前的Kafka包,Zookeeper包在同一目錄下,這樣方便修改管理.

    2.修改D:\KafkaTool\kafka-manager-1.3.3.16\conf目錄下的application.conf檔案,將kafka-manager.zkhosts修改為本地或需要的遠端伺服器連結,這裡修改為

kafka-manager.zkhosts="localhost:2181"

    3.為了使Kafka-manager相容Kafka和Zookeeper,這裡需要修改Kafka和Zookeeper的一些配置檔案,在D:\KafkaTool\zookeeper-3.4.12\conf目錄下修改zoo.cfg,修改的主要內容為:

dataDir=D:\\KafkaTool\\zookeeper-3.4.12\\data
dataLogDir=D:\\KafkaTool\\zookeeper-3.4.12\\log

   4.在D:\KafkaTool\kafka_2.10-0.10.2.1\config的操作目錄下修改server.properties(之前安裝操作做了一些修改,這裡補充),主要修改內容為:

# The number of messages to accept before forcing a flush of data to disk
log.flush.interval.messages=10

# The maximum amount of time a message can sit in a log before we force a flush
log.flush.interval.ms=320000
 

# root directory for all kafka znodes.
zookeeper.connect=localhost:2181

# Timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=18000

主要是為了避免日誌的短期操作快取過期.在這期間開啟Kafka可能會出現以下類似的錯誤(只擷取核心的錯誤日誌資訊)

        at java.lang.Thread.run(Thread.java:745)
Caused by: java.nio.file.FileSystemException: D:\KafkaTool\kafka_2.10-0.10.2.1\k
afka-logs\haige-0\00000000000000000000.log -> D:\KafkaTool\kafka_2.10-0.10.2.1\k
afka-logs\haige-0\00000000000000000000.log.deleted: 另一個程式正在使用此檔案，進
程無法訪問。
 

這是Kafka在Window平臺上存在的一個Bug,只能手動刪除\kafka-logs裡的日誌檔案重啟kafka,才能再次正確執行Kafka.至於Kafka-manager,要刪除D:\KafkaTool\kafka-manager-1.3.3.16\bin目錄下之前執行產生的日誌資料夾application.home_IS_UNDEFINED和RUNNING_PID檔案.在必要時還要刪除D:\KafkaTool\zookeeper-3.4.12\log資料夾下的version-2資料夾和D:\KafkaTool\zookeeper-3.4.12\data資料夾下的version-2.

    5.點選D:\KafkaTool\kafka-manager-1.3.3.16\bin資料夾下的kafka-manager.bat,執行kafka-manager.執行成功,出現以下頁面

 執行出錯,該CMD執行框會閃退,這時可以檢查之前的步驟都做了嗎?

 6.在瀏覽器輸入http://localhost:9000/訪問kafka-manager的主頁

   7.在Cluster下拉框選擇Add Cluster新增一個叢集節點,這裡簡單操作,在輸入框Cluster Name和Cluster Zookeeper Hosts填入必要值即可,其他選項預設.點選Save儲存即可

  8.這時就可以在網頁上對剛才新建的haige叢集節點做訊息佇列的管理了