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:表示消费状态刷新最新时间