Kafka监控工具KafkaOffsetMonitor

你的名字 2022-06-18 03:15 245阅读 0赞

原文： http://blog.csdn.net/panguoyuan/article/details/44567259

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：

**\[html\]**  [view plain][]   [copy][view plain]

[print][view plain] [?][view plain] [![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  \#!/bin/bash  
2.  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.截图演示

![Center][]

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

![Center 1][]

![Center 2][]

问题总结

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

[Java]: http://lib.csdn.net/base/javase
[view plain]: http://blog.csdn.net/panguoyuan/article/details/44567259#
[CODE]: https://code.csdn.net/assets/CODE_ico.png
[CODE_CODE]: https://code.csdn.net/snippets/626040
[ico_fork.svg]: https://code.csdn.net/assets/ico_fork.svg
[ico_fork.svg 1]: https://code.csdn.net/snippets/626040/fork
[Center]: /images/20220618/e14a68297fd44eda8c2efded9788f486.png
[Center 1]: /images/20220618/1e3dee53620a4541abd9a27d9f24ea9f.png
[Center 2]: /images/20220618/5b3c156a56f34c2598afcca763311316.png