開源didi kafka-manager使用

最近在尋找可以監控kafka集群的軟件，發現滴滴開源的項目不錯，趕緊動手用起來。

開源地址：https://github.com/didi/Logi-KafkaManager

本文主要記錄使用中存在的問題：

一、數據庫版本

1.  默認的數據庫使用的是MySQL5.7，如果使用的是MySQL8.0+的需要自己下載源碼編譯后部署安裝。下載地址

2. 修改根目錄下的pom.xml文件中依賴mysql-connector-java的版本信息為8.0.20

 

 

3.  windows環境使用cmd命令，進入到項目目錄，執行mvn install，打包

mvn install

（如果執行的時候’mvn’ 不是內部或外部命令，也不是可運行的程序，自行百度）

 

 打包成功的jar文件在 Logi-KafkaManager-master\kafka-manager-web\target 目錄下

二、修改配置文件

1.  修改服務默認端口8080為18080

2.  修改數據庫的連接配置信息，根據提供的SQL文件創建數據庫和表

3.  開啟JMX端口，在啟動kafka命令前加上JMX_PORT=9999 即可

JMX_PORT=9999 bin/kafka-server-start.sh -daemon config/server.properties

 

三、web控制台配置

1.  接入集群，zookeeper地址最后的名稱寫自己zookeeper的連接名稱，沒有配置的就是/ ，例如  192.168.1.1:2181/  

2.  新建Region，Broker列表填寫的是kafka的配置文件中broker.id的值

3.  新建邏輯集群，RegionIdList就是上一步添加過的Region，一個Region只屬於一個邏輯集群。如果節點很多的話，這樣自上而下方便管理

 

四、問題匯總

• kafka manger 報錯java.rmi.ConnectException: Connection refused to host: 127.0.0.1

  在kafka安裝目錄下的kafka-run-class.sh中
  
  # JMX settings
  if [ -z "$KAFKA_JMX_OPTS" ]; then
    KAFKA_JMX_OPTS="-Djava.rmi.server.hostname=192.168.15.23 
    -Dcom.sun.management.jmxremote 
  　-Dcom.sun.management.jmxremote.authenticate=false
    -Dcom.sun.management.jmxrem ote.ssl=false "
  fi
  增加一項-Djava.rmi.server.hostname=192.168.15.23

   

 

友情參考鏈接：

安裝 https://blog.csdn.net/wsdc0521/article/details/105833978

使用：https://mp.weixin.qq.com/s/pYYgppGaj3RDD4libORynw

架構：https://blog.csdn.net/yezonggang/article/details/113106244