Kafka笔记--监控系统KafkaOffsetMonitor

时间:2022-11-21 22:31:30

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