下载打包
release下载:https://github.com/yahoo/kafka-manager/releases
源码位置:https://github.com/yahoo/kafka-manager
从上面两处获取的都是源码,需要自己打包,才可以使用
1、进入解压后的 Kafka-manager 目录,执行下面的命令:./sbt clean dist。如果之前从来没有用过Play框架,这个步骤会需要一定时间,主要是下载依赖的jar包,使用aliyun的私服可以让这个过程缩短很多。
2、命令执行完成后,在 target/universal
目录中会生产一个zip压缩包kafka-manager-x.x.x.zip
。将压缩包拷贝到要部署的目录下解压。
3、在解压后的conf
目录中打开 application.conf
文件,修改其中的配置信息,最主要的内容为:
kafka-manager.zkhosts="192.168.1.221:2181,192.168.1.222:2181,192.168.1.223:2181"
配置为Kafka的 zookeeper 服务器。你还可以通过环境变量ZK_HOSTS
配置这个参数值。
4、可以设置为登录验证,增强访问的安全性:
修改kafka-manager-1.3.3.21/conf/application.conf文件,使Kafka-Manager使用账号登录
basicAuthentication.username="admin" basicAuthentication.password="admin"
启动,默认端口9000:
- bin/kafka-manager
- nohup bin/kafka-manager -Dhttp.port=8090 > nohup.out 2>&1 &
配置集群
点击【Cluster】>【Add Cluster】打开如下添加集群的配置界面:
输入集群的名字(如Kafka-Cluster-1
)和 Zookeeper 服务器地址(如localhost:2181
)。
选择最接近的Kafka版本,直接保存即可
注意:如果没有在 Kafka 中配置过 JMX_PORT,千万不要选择第一个复选框。 Enable JMX Polling 如果选择了该复选框,Kafka-manager 可能会无法启动。
参考:
1、https://blog.csdn.net/yuan_xw/article/details/79188565
2、https://cloud.tencent.com/developer/article/1349478
3、https://github.com/yahoo/kafka-manager