kafka-manager监控工具安装

kafka-manager监控工具安装

1、下载源码文件


安装sbt
sbt是scala的打包构建工具。
下载、安装：

下载，编绎，生成发布包：

git clone
cd kafka-manager
sbt clean dist

生成的包会在kafka-manager/target/universal 下面。生成的包只需要java环境就可以运行了，在部署的机器上不需要安装sbt。

打好包好，在部署机器上解压，修改好配置文件，就可以运行了。
编译用的jdk和运行的时候jdk版本一致。

unzip kafka-manager-1.0-SNAPSHOT.zip

2、配置文件
vi /usr/local/kafka-manager/conf

kafka-manager.zkhosts="192.168.12.127:2181,192.168.12.128:2181,192.168.12.129:2181"
kafka-manager.zkhosts=${?ZK_HOSTS}
pinned-dispatcher.type="PinnedDispatcher"
pinned-dispatcher.executor="thread-pool-executor"

[root@dn9 bin]# pwd
/usr/local/kafka-manager/bin

[root@dn9 bin]# cat start.sh
#!/bin/bash
nohup /usr/local/kafka-manager/bin/kafka-manager -Dconfig.file=/usr/local/kafka-manager/conf/application.conf > /usr/local/kafka-manager/bin/km.log &


chmod +x start.sh

3、配置
Add Cluster
beijing_cloud
192.168.12.127:2181,192.168.12.128:2181,192.168.12.129:2181


4、报错：
Yikes! Ask timed out on [ActorSelection[Anchor(akka://kafka-manager-system/), Path(/user/kafka-manager)]] after [1000 ms] Try again.
刷新下等待一会就好了。

kafka-manager-1.0-SNAPSHOT.zip如果是jdk1.7编译的话，部署环境也需要时jdk1.7才可以运行不然无法启动！


开源源码
http://www.iteblog.com/archives/1264