KafkaOffsetMonitor使用方法

(1)下载jar包

去网上搜索KafkaOffsetMonitor即可。

我这里共享了我的百度云连接:http://yun.baidu.com/s/1nvGjbDn

如果某一天我这个取消共享了,大家去网上随便查找一个就可以。也可以在博客上给我留言,我来继续分享。

(2)将jar包上传到Linux上

我这里在kafka的bin目录下面,建立了一个kafka-monitor的目录,然后将jar包上传上去。

(3)编写脚本文件

脚本文件内容如下:

#!/bin/sh

java -cp KafkaOffsetMonitor-assembly-0.2.0.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --zk 192.168.93.128:2181 --port 8089 --refresh 10.seconds --retain 1.days

(4)运行脚本文件

设置脚本权限:chmod 777 kafka-monitor.sh

运行脚本文件:./kafka-monitor.sh &   (后面加上&可以后台运行脚本

运行成功之后的效果如下图:

(5)打开浏览器窗口:

浏览器地址:192.168.93.128:8090

正常打开之后的效果如下图:

topic:创建时topic名称

partition:分区编号

offset:表示该parition已经消费了多少条message

logSize:表示该partition已经写了多少条message

Lag:表示有多少条message没有被消费。

Owner:表示消费者

Created:该partition创建时间

Last Seen:消费状态刷新最新时间。

--END--

原文地址:https://www.cnblogs.com/quchunhui/p/5378336.html