Kafka监控工具KafkaOffsetMonitor

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的大小。