kafka-manager监控工具安装

kafka-manager监控工具安装

1、下载源码文件
https://github.com/yahoo/kafka-manager
安装sbt

sbt是scala的打包构建工具。
http://www.scala-sbt.org/download.htmlubuntu下载、安装：
下载，编绎，生成发布包：

git clone https://github.com/yahoo/kafka-manager
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