kafka manager安装和使用

1、GitHub下载kafka manager的源码并且编译

链接:https://github.com/yahoo/CMAK.

2、编译命令和编译完成后的文件路径

编译命令:sbt clean dist
编译成功后的文件位置在target目录的子目录下面如下图
kafka manager安装和使用

3、修改配置文件里面zookeeper集群的配置

配置文件路径:kafka-manager/conf/application.conf
kafka manager安装和使用

4、修改kafka manager里面conf目录下面application.conf里面的zookeeper集群的配置

kafka-manager.zkhosts="[ip01:2181,ip02:2181]"
eg:kafka-manager.zkhosts=“ps-01:2181,ps02:2181”
kafka manager安装和使用

5、后台挂载启动kafka manager命令

nohup ./kafka-manager -Dhttp.port=9098 >/dev/null 2>&1 &

Q&&A、启动kafka manager遇到的问题

1、集群里的kafka需要开启JXM

1.1编辑kafka里面的kafka-run-class.sh脚本,并添加下面的内容

-Djava.rmi.server.hostname=ps-01 -Djava.net.preferIPv4Stack=true
ps: xxxhostname填的是远程主机名或ip(集群的每台机器都改)

kafka manager安装和使用

1.2、 编辑kafka里面的kafka-server-start.sh脚本,并添加下面的内容

export JMX_PORT=9999
kafka manager安装和使用

1.3 停止和重新启动kafka集群

停止kafka : ./kafka-server-stop.sh …/config/server.properties
进程守护模式启动kafka : nohup ./kafka-server-start.sh …/config/server.properties >/dev/null 2>&1 &

2、kafka-manager使用启动命令启动后,外网无法访问

本机是可以访问的,外网不能访问,是端口没有开放,需要使用xshell做一个代理,然后访问本地的端口就可以访问了;

3、启动kafka-manager的时候端口占用的解决办法

启动kafak-manager的时候,换默认的端口
-Dhttp.port=9099

参考文章:
[1]: https://www.jianshu.com/p/f65e76efe895
[2]:https://www.jianshu.com/p/af5097651cee