1.下載KafkaOffsetMonitor-assembly-0.2.0.jar 網盤地址：http://pan.baidu.com/s/1eQgYZOA  密碼：rd5y

2.在伺服器上建立kafka-offset-console目錄

3.把下載好的檔案上傳到剛剛建立的目錄下

4.建立監控程式執行的產生的日誌輸出目錄：/app/kafka-offset-console/logs

5.該jar檔案已經包含所有UI所需的資原始檔，用java命令執行該jar包即可，所以需要編寫一個啟動指令碼

kafka-offset-console-start.sh：

#!/bin/bash
java -Xms512M -Xmx512M -Xss1024K -XX:PermSize=256m -XX:MaxPermSize=512m -cp KafkaOffsetMonitor-assembly-0.2.0.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --zk 192.168.1.100:2181,192.168.1.101:2181,192.168.1.102:2181 --port 8086 --refresh 10.seconds --retain 7.days 1>/app/kafka-offset-console/logs/stdout.log 2>/app/kafka-offset-console/logs/stderr.log &
 

8.截圖演示

topic：建立時topic名稱
partition：分割槽編號
offset：表示該parition已經消費了多少條message
logSize：表示該partition已經寫了多少條message
Lag：表示有多少條message沒有被消費。
Owner：表示消費者
Created：該partition建立時間
Last Seen：消費狀態重新整理最新時間

問題總結

1、當KafkaOffsetMonitor執行長時間之後，JVM記憶體可能不夠，導致在頁面上操作遲遲不能響應，需要調整JVM的大小。