zooKeeper和kafka安装的都是apache的。业务需要对kafka监控,网上有很多,但这里里面有坑。
我这边使用过下面三种jar包(下面的jar包只需要一个且只在一个安装过zookeeper节点上运行即可)
KafkaOffsetMonitor-assembly-0.4.6.jar
KafkaOffsetMonitor-assembly-0.2.1.jar
KafkaOffsetMonitor-assembly-0.2.0.jar
最后发现只使用KafkaOffsetMonitor-assembly-0.2.0.jar这个jar包就成功了,有些环境不同可以多测试别的jar包试试可能就会成功。上面两个jar运行时有各种各样的错误,例如web界面无法展示等
1.我的集群环境
zookeeper :zookeeper-3.4.8
kafka:kafka_2.11-0.10.0.0
java: java version "1.8.0_172"
2.自己写一个启动脚本kakfamonitor.sh
#!/bin/bash java -Xms512M -Xmx512M -Xss1024K -XX:PermSize=256m -XX:MaxPermSize=512m -cp KafkaOffsetMonitor-assembly-0.2.0.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --zk 192.168.*.*:2181,192.168.*.*:2181,192.168.*.*:2181 --port 7878 --refresh 10.seconds --retain 3.days 1>/data/kafkalogs/stdout.log 2>/data/kafkalogs/stderr.log &
3.在浏览器查看监控界面