1. 程式人生 > >kafka-manager配置和使用

kafka-manager配置和使用

kafka-manager配置

  最主要配置就是用於kafka管理器狀態的zookeeper主機。這可以在conf目錄中的application.conf檔案中找到。

kafka-manager.zkhosts="my.zookeeper.host.com:2181"

  當然也可以宣告為zookeeper叢集。

kafka-manager.zkhosts="my.zookeeper.host.com:2181,other.zookeeper.host.com:2181"

  另外也可以通過環境變數ZK_HOSTS來表示。

ZK_HOSTS="my.zookeeper.host.com:2181"

  自定義kafka-manager功能,類似於許可權管理。

application.features=["KMClusterManagerFeature","KMTopicManagerFeature","KMPreferredReplicaElectionFeature","KMReassignPartitionsFeature"]
  • KMClusterManagerFeature - allows adding, updating, deleting cluster from Kafka Manager
  • KMTopicManagerFeature - allows adding, updating, deleting topic from a Kafka cluster
  • KMPreferredReplicaElectionFeature - allows running of preferred replica election for a Kafka cluster
  • KMReassignPartitionsFeature - allows generating partition assignments and reassigning partitions

kafka-manager打包

  下面的命令將建立一個zip檔案,可用於部署應用程式。

./sbt clean dist

  更多的玩法配置請參考:production deployment/configuration

.

  這個命令執行的會很慢,而且可能會失敗,要反覆執行幾次。不過我已經執行好了,訪問連結: https://pan.baidu.com/s/1123fRCT9ywEgiV6HjzSluw 提取碼: r86e 。

kafka-manager執行

  經過上一步打包好之後會生成一個zip,具體zip的位置可以看輸出日誌。解壓zip檔案,進入kafka-manager目錄。

bin/kafka-manager

  或者指定配置檔案位置和埠

bin/kafka-manager -Dconfig.file=/path/to/application.conf -Dhttp.port=8080

  也可以指定java home的位置

 bin/kafka-manager -java-home /usr/local/oracle-java-8

  修改conf/application.conf如下屬性

play.http.context = "/kafka-manager"
kafka-manager.zkhosts="localhost:2181"
kafka-manager.zkhosts=${?ZK_HOSTS}
application.features=["KMClusterManagerFeature","KMTopicManagerFeature","KMPreferredReplicaElectionFeature","KMReassignPartitionsFeature"]

  預設的埠是9000

kafka-manager介面詳情

  叢集監控資訊

   

  

   Topic配置資訊

  

   Topic對應的消費分組資訊

   

   消費者消費詳情

  

  消費者列表資訊

   

   Borker資訊