技术环境:CentOS6.5 + kafka-manager2.0 + kafka_2.12-2.5.0
技术背景:为了方便对kafka内部数据进行监控和管理,便找到了kafka-manager,这次使用的是2.0版本,其最新github版本已升至3.0.0.5
下载和安装
kafka-manager由yahoo开源,可以到yahoo的github主页下载已经编译好的二进制以及未编译的源代码
下面是主页地址
https://github.com/yahoo/CMAK/releases
直接可以下载运行的二进制文件
https://github.com/yahoo/CMAK/releases/download/3.0.0.5/cmak-3.0.0.5.zip
需要编译的源代码
https://github.com/yahoo/CMAK/archive/3.0.0.5.zip
如果使用源码,那会是一个漫长的编译过程,整个流程另起篇幅讲解,这里不再讲述,这里只讲解二进制版本
二进制版本可以直接运行,首先需要配置 bin/application.conf 文件,这个配置比较简单,只需要配置一行获取到zookeeper的位置就行了,如下所示
kafka-manager.zkhosts=”localhost:2181″
#kafka-manager.zkhosts=${?ZK_HOSTS}
找到kafka-manager.zkhosts=${?ZK_HOSTS}这一行,注释掉,然后添加一行kafka-manager.zkhosts=”localhost:2181″
因为只有一个kafka节点,使用的是其自带的zookeeper,所以是localhost:2181,如果有一个集群,可以在后面追加。比如
kafka-manager.zkhosts=”ip1:2181,ip2:2181″
也可以通过直接使用ZK_HOSTS环境变量来进行配置,比如
讲ZK_HOSTS=”my.zookeeper.host.com:2181″添加至.bashrc文件中
两种风格看个人喜好,皆可行
配置好后直接启动(保证zookeeper和kafka的服务正常)
bin/kafka-manager -Dconfig.file=conf/application.conf
kafka-manager的默认访问端口是9000,如果不是9000,也可以在启动时通过-Dhttp.port参数来指定具体的端口号,如下所示,便将其修改为8080
bin/kafka-manager -Dconfig.file=conf/application.conf -Dhttp.port=8080 &
正常启动后,通过浏览器访问 http://localhost:8080/ 即可看到kafka-manger的界面