1.下載jar包
已經(jīng)編譯好的 ,github上的需要google聯(lián)網(wǎng)
http://pan.baidu.com/s/1nuvbAPz
KafkaOffsetMonitor-assembly-0.2.0.jar
2.start_monitor.sh 啟動(dòng)腳本
java -Xms512M -Xmx512M -Xss1024K -XX:PermSize=256m -XX:MaxPermSize=512m -cp KafkaOffsetMonitor-assembly-0.2.0.jar
com.quantifind.kafka.offsetapp.OffsetGetterWeb
--zk master:2181,slave1:2182,slave2:2181
--port 8086
--refresh 10.seconds --retain 7.days
1>/home/hadoop/kafka/kafka_monitor/stdout.log
2>/home/hadoop/kafka/kafka_monitor/stderr.log &
3.執(zhí)行腳本
localhost:8086訪問

Paste_Image.png