在 kafka的bin目錄下進(jìn)行下面的操作
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的相關(guān)的信息徽诲。
從百度網(wǎng)盤(pán)下載：百度下載
KafkaOffsetMonitor-assembly-0.2.0.jar
chmod +x kafka_monitor
nohup? ./kafka_monitor ?&
http://ip:8089
出現(xiàn)如下圖差不多弱卡，只是我已經(jīng)有數(shù)據(jù)了：
藍(lán)色表示: 總提交的數(shù)據(jù)
紅色表示： 等待處理的數(shù)據(jù)
線綠表示：已處理的數(shù)據(jù)
