kafka-manager配置和使用

发布网友发布时间：2024-10-01 04:58

共1个回答

热心网友时间：2024-11-08 01:06

在配置kafka-manager时，最关键的是设置用于管理器状态的zookeeper主机。这一配置可以在conf目录下的application.conf文件中找到。

例如，可以这样设置zookeeper主机：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中配置自定义功能，例如：application.features=["KMClusterManagerFeature","KMTopicManagerFeature","KMPreferredReplicaElectionFeature","KMReassignPartitionsFeature"]。

接下来是打包kafka-manager，使用以下命令创建zip文件，以便于部署应用程序：./sbt clean dist。有关更多的玩法配置，请参考：production deployment/configuration。

执行该命令可能需要较长时间，也可能失败，需要多次尝试。我已经完成了打包，访问链接: pan.baidu.com/s/1123fRC... 提取码: r86e。

打包完成后，会生成一个zip文件，具体位置可以在输出日志中查看。解压zip文件，进入kafka-manager目录。

运行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对应的消费分组信息、消费者消费详情、消费者列表信息以及Broker信息。