Kafka监控工具：KafkaOffsetMonitor

一、简介

kafka 貌似没有提供 web 界面来管理 topic，可能是为了 kafka 的搞吞吐量吧，但是 GitHub 上有人就做了：KafkaOffsetMonitor 的 GitHub ，参考这里

二、使用

1. 下载

   • Github上下载的 jar 貌似有问题，这里给出一个，链接: https://pan.baidu.com/s/1k63ZC8uSdaQGoukd9IJ0rA 提取码: ha4b

2. 在 jar 同目录编写 sh 启动脚本:kafka-web.sh

   #!/bin/sh
   java -Xms512M -Xmx512M -Xss1024K -XX:PermSize=256m -XX:MaxPermSize=512m  -cp KafkaOffsetMonitor-assembly-0.2.0.jar  com.quantifind.kafka.offsetapp.OffsetGetterWeb --port 8888 --zk 127.0.0.1:2181 --refresh 5.minutes --retain 7.days 1> kakfa.offset.monitor.logs.stdout.log 2>kafka.offset.monitor.logs.stderr.log &
   

   • 参数说明
     • zk ：zookeeper主机地址，如果有多个，用逗号隔开
     • port ：应用程序端口，即网页访问 kafka 界面的端口
     • refresh ：应用程序在数据库中刷新和存储点的频率
     • retain ：在db中保留多长时间
     • dbName ：保存的数据库文件名，默认为offsetapp, 见下图

3. 赋能执行

   chmod u+x kafka-web.sh
   

4. 在启动 zk 和 kafka 的前提下，执行kafka-web.sh

   ./kafka-web.sh