1.下载KafkaOffsetMonitor-assembly-0.2.0.jar 网盘地址：http://pan.baidu.com/s/1eQgYZOA  密码：rd5y

2.在服务器上创建kafka-offset-console目录

3.把下载好的文件上传到刚刚创建的目录下

4.创建监控程序运行的产生的日志输出目录：/app/kafka-offset-console/logs

5.该jar文件已经包含所有UI所需的资源文件，用java命令运行该jar包即可，所以需要编写一个启动脚本

kafka-offset-console-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.100:2181,192.168.1.101:2181,192.168.1.102:2181 --port 8086 --refresh 10.seconds --retain 7.days 1>/app/kafka-offset-console/logs/stdout.log 2>/app/kafka-offset-console/logs/stderr.log &

6.授权执行权限：chmod +x kafka-offset-console-start.sh
7.启动KafkaOffsetMonitor监控程序：./kafka-offset-console-start.sh

8.截图演示

topic：创建时topic名称
partition：分区编号
offset：表示该parition已经消费了多少条message
logSize：表示该partition已经写了多少条message
Lag：表示有多少条message没有被消费。
Owner：表示消费者
Created：该partition创建时间
Last Seen：消费状态刷新最新时间

问题总结

1、当KafkaOffsetMonitor运行长时间之后，JVM内存可能不够，导致在页面上操作迟迟不能响应，需要调整JVM的大小。