kafka-manager配置和使用
阿新 • • 發佈:2018-11-20
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資訊