前期博客
基於Web的Kafka管理器工具之Kafka-manager的編譯部署詳細安裝 (支持kafka0.8、0.9和0.10以后版本)(圖文詳解)
基於Web的Kafka管理器工具之Kafka-manager啟動時出現Exception in thread "main" java.lang.UnsupportedClassVersionError錯誤解決辦法(圖文詳解)
然后
第一次進入web UI要進行kafka cluster的配置,都是一些比較簡單的操作。
配置集群
點擊【Cluster】>【Add Cluster】打開如下添加集群的配置界面:
它會自動識別出,當前,你所用的kafka版本
當然,這里,大家后期還可以微調kafka的版本。當然是與自己集群的版本一致!
當然,大家也可以給輸入集群的名字(如Kafka-Cluster-1
)和 Zookeeper 服務器地址(如localhost:2181
)。
我這里給
Cluster Nmae賦值為kafka
Cluster Zookeeper Hosts為master:2181,slave1:2181,slave2:2181
kafka version,就選擇我當前用的版本(它會默認識別到)。
注意: 如果沒有在 Kafka 中配置過 JMX_PORT,千萬不要選擇第一個復選框。
Enable JMX Polling
如果選擇了該復選框,Kafka-manager 可能會無法啟動。
我這里,是沒有配置JMX_PORT
然后,其他broker的配置可以根據自己需要進行配置。如下
默認情況下,點擊【保存】時,會提示幾個默認值為1
的配置錯誤,需要配置為>=2
的值。保存成功后,提示如下。
然后,如下
點擊【Go to cluster view.】打開當前的集群界面。
在集群界面顯示了主題和Broker的個數,點擊數字可以查看具體的信息。
同時在頂部多了好幾個菜單,可以查看集群、Broker、主題等信息。
新建主題
點擊【Topic】>【Create】可以方便的創建並配置主題。如下顯示。
這里,推薦去先看下我下面的博客,
kafka的topic命名技巧
更多的其他詳細操作
關於kafka-manager的其他功能和操作可以參考官網:https://github.com/yahoo/kafka-manager
參考
Apache Kafka 入門 - Kafka-manager的基本配置和運行