在 kafka的bin目录下进行下面的操作

mkdir kafka_monitor

cd kafka_monitor

vim kafka_monitor

#! /bin/bash

java -cp KafkaOffsetMonitor-assembly-0.2.0.jar \

com.quantifind.kafka.offsetapp.OffsetGetterWeb \

--zk zoo01:2181,zoo02:2181,zoo03:2181 \ 

--port 8089 \

--refresh 10.seconds \

--retain 1.days

-zk  后面接的是zookeeper的相关的信息。

从百度网盘下载：百度下载

KafkaOffsetMonitor-assembly-0.2.0.jar

chmod +x kafka_monitor

nohup  ./kafka_monitor  &

http://ip:8089

出现如下图差不多，只是我已经有数据了：

蓝色表示: 总提交的数据

红色表示： 等待处理的数据

线绿表示：已处理的数据