kafka-manager配置

　　最主要配置就是用于kafka管理器狀態(tài)的zookeeper主機(jī)。這可以在conf目錄中的application.conf文件中找到。

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

　　當(dāng)然也可以聲明為zookeeper集群。

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

　　另外也可以通過環(huán)境變量ZK_HOSTS來表示。

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

　　自定義kafka-manager功能，類似于權(quán)限管理。

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打包

　　下面的命令將創(chuàng)建一個zip文件，可用于部署應(yīng)用程序。

./sbt clean dist

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

　　這個命令執(zhí)行的會很慢，而且可能會失敗，要反復(fù)執(zhí)行幾次。不過我已經(jīng)執(zhí)行好了，訪問鏈接: https://pan.baidu.com/s/1123fRCT9ywEgiV6HjzSluw 提取碼: r86e 。

kafka-manager運(yùn)行

　　經(jīng)過上一步打包好之后會生成一個zip，具體zip的位置可以看輸出日志。解壓zip文件，進(jìn)入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"]

　　默認(rèn)的端口是9000

kafka-manager界面詳情

　　集群監(jiān)控信息

?　　

　　

?　　Topic配置信息

　　

?　　Topic對應(yīng)的消費(fèi)分組信息

?　　

?　　消費(fèi)者消費(fèi)詳情

　　

　　消費(fèi)者列表信息

?　　

?　　Borker信息

　　

　　

?

　　附：Kafka-Manager API

轉(zhuǎn)載于:https://www.cnblogs.com/hujunzheng/p/9986586.html

總結(jié)

以上是生活随笔為你收集整理的kafka-manager配置和使用的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。