下載打包
release下載:https://github.com/yahoo/kafka-manager/releases
源碼位置:https://github.com/yahoo/kafka-manager
從上面兩處獲取的都是源碼,需要自己打包,才可以使用
1、進入解壓后的 Kafka-manager 目錄,執行下面的命令:./sbt clean dist。如果之前從來沒有用過Play框架,這個步驟會需要一定時間,主要是下載依賴的jar包,使用aliyun的私服可以讓這個過程縮短很多。
2、命令執行完成后,在 target/universal
目錄中會生產一個zip壓縮包kafka-manager-x.x.x.zip
。將壓縮包拷貝到要部署的目錄下解壓。
3、在解壓后的conf
目錄中打開 application.conf
文件,修改其中的配置信息,最主要的內容為:
kafka-manager.zkhosts="192.168.1.221:2181,192.168.1.222:2181,192.168.1.223:2181"
配置為Kafka的 zookeeper 服務器。你還可以通過環境變量ZK_HOSTS
配置這個參數值。
4、可以設置為登錄驗證,增強訪問的安全性:
修改kafka-manager-1.3.3.21/conf/application.conf文件,使Kafka-Manager使用賬號登錄
basicAuthentication.username="admin" basicAuthentication.password="admin"
啟動,默認端口9000:
- bin/kafka-manager
- nohup bin/kafka-manager -Dhttp.port=8090 > nohup.out 2>&1 &
配置集群
點擊【Cluster】>【Add Cluster】打開如下添加集群的配置界面:
輸入集群的名字(如Kafka-Cluster-1
)和 Zookeeper 服務器地址(如localhost:2181
)。
選擇最接近的Kafka版本,直接保存即可
注意:如果沒有在 Kafka 中配置過 JMX_PORT,千萬不要選擇第一個復選框。
Enable JMX Polling
如果選擇了該復選框,Kafka-manager 可能會無法啟動。
參考:
1、https://blog.csdn.net/yuan_xw/article/details/79188565
2、https://cloud.tencent.com/developer/article/1349478
3、https://github.com/yahoo/kafka-manager