kafka集群监控KafkaOffsetMonitor

黑窗口的kafka集群没有监控，可以使用三方开源的监控工具，KafkaOffsetMonitor这个工具耦合性比较低，单用于监控比较适合而且部署很简单。 

下载地址：http://pan.baidu.com/s/1qXJa7QO

服务器上创建文件夹 kafkamonitor，把jar报上传到服务器

创建start.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.1.111:2181,192.168.1.131:2182,192.168.1.132:2181 --port 8787 --refresh 10.seconds --retain 7.days 1>/home/fulihui/pkg/kafkamonitor/stdout.log 2>/home/fulihui/pkg/kafkamonitor/stderr.log &

创建stop.sh

#!/bin/bash
killnum=`jps | grep OffsetGetterWeb | awk '{print $1}'`
kill -9 ${killnum}
echo "OK...."

http://192.168.1.111:8787/#/group/



以上图中参数含义解释如下：

　　　topic：创建时topic名称

　　　partition：分区编号

　　　offset：表示该parition已经消费了多少条message

　　　logSize：表示该partition已经写了多少条message

　　　Lag：表示有多少条message没有被消费。

　　　Owner：表示消费者

　　　Created：该partition创建时间

　　　Last Seen：消费状态刷新最新时间。