KafkaOffsetMonitor

下载安装

使用方法

This is a small webapp, you can run it locally or on a server, as long as you have access to the ZooKeeper nodes controlling kafka.

1	java -cp KafkaOffsetMonitor-assembly-0.2.1.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --zk serveIp1,serveIp2,serveIp3 --port 8080 --refresh 10.seconds --retain 2.days

The arguments are:

ZK: the ZooKeeper hosts;
port: on what port will the app be available;
refresh: how often should the app refresh and store a point in the DB;
retain: how long should points be kept in the DB;
dbName: where to store the history (default ‘offsetapp’);

Kafka Manager

源码地址

安装

Kafka Manager安装

sbt安装

1
2
3

curl https://bintray.com/sbt/rpm/rpm > bintray-sbt-rpm.repo
sudo mv bintray-sbt-rpm.repo /etc/yum.repos.d/
sudo yum install sbt

下载，编译

下载，并编译源码：

1
2
3

git clone https://github.com/yahoo/kafka-manager
cd kafka-manager
sbt clean dist

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

打包部署

打好包好，在部署机器上解压，修改好配置文件，就可以运行了。

解压：

1	unzip kafka-manager-1.0-SNAPSHOT.zip

配置运行

配置

修改conf/application.conf，把kafka-manager.zkhosts改为自己的zookeeper服务器地址

1	kafka-manager.zkhosts="localhost:2181"

启动

1	./bin/kafka-manager -Dconfig.file=./conf/application.conf -Dhttp.port=8080

kafka-manager其他方面

查看帮助

1	./bin/kafka-manager -h

后台运行

1	nohup ./kafka-manager -Dconfig.file=../conf/application.conf >/dev/null 2>&1 &

默认http端口是9000，可以修改配置文件里的http.port的值，或者通过命令行参数传递：

1	./kafka-manager -Dhttp.port=9001

如果不想自己编译源文件，也可以通过下面的地址直接下载，kafka-manager-1.0-SNAPSHOT.zip下载地址

Kafka-web-console