KafkaOffsetMonitor下载链接： http://download.csdn.net/detail/changong28/7930337github官方：https://github.com/quantifind/KafkaOffsetMonitor/
   　　　　　https://github.com/quantifind/KafkaOffsetMonitor/releases/tag/v0.2.1
安装部署： http://www.cnblogs.com/Leo_wl/p/4564699.html
　　　　　 http://www.aboutyun.com/thread-9893-1-1.html

1. 将KafkaOffsetMonitor下载后解压

2. 编写启动脚本如下，并保存为 kafka_offset_monitor.sh

#! /bin/bash

java -cp KafkaOffsetMonitor-assembly-0.2..jar \

 com.quantifind.kafka.offsetapp.OffsetGetterWeb \

 --zk node4:,node3: \

 --port  \

 --refresh .seconds \

 --retain .days

3. 启动kafka集群

4. 启动KafkaOffsetMonitor： 执行 ./kafka_offset_monitor.sh

5. 打开控制台 http://192.168.1.160:8089

一些参数含义的解释

• Topic：创建Topic名称
• Partition：分区编号
• Offset：表示该Parition已经消费了多少Message
• LogSize：表示该Partition生产了多少Message
• Lag：表示有多少条Message未被消费
• Owner：表示消费者
• Created：表示该Partition创建时间
• Last Seen：表示消费状态刷新最新时间