我装的kafka版本0.10.2，kafkaOffsetMonitor 下载地址 密码: qi8a                                   安装包是集成插件的，直接启动就行。

启动脚本

#!/bin/bash

java -Xms512M -Xmx512M -Xss1024K -XX:PermSize=256m -XX:MaxPermSize=512m -cp KafkaOffsetMonitor-assembly-0.3.0-SNAPSHOT.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --offsetStorage kafka --zk 127.0.0.1:2181 --port 8080 --refresh 10.seconds --retain 2.days 1>/tmp/kafkamonitorlogs/stdout.log 2>/tmp/kafkamonitorlogs/stderr.log &

停止脚本

#!/bin/bash 

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

参数说明见https://github.com/quantifind/KafkaOffsetMonitor，启动后访问如果所示

KafkaOffsetMonitor监控topic

consumer group消费情况

offset是当前的消费位置，logSize是消息日志尾，lag是还剩多少没消费。

consumer消费曲线图

蓝线对应logSize，红线是lag，绿线对应offset

上边的数据配置，3个partition，3个replica，consume只有一个线程实例在消费