1.介紹
一般情況下，功能簡單的kafka項目 使用運維命令+kafka Offset Monitor 就足夠用了。
2、使用
2.1 部署
github下載jar包 KafkaOffsetMonitor-assembly-0.2.0.jar 地址：https://github.com/quantifind/KafkaOffsetMonitor/releases 注意github版本需要翻牆下載google文件
可以下載百度網盤：https://pan.baidu.com/s/1ntzIUPN 這是大牛已經整好了的
2.2 啟動 refresh-刷新時間 retain-駐留時間
步驟一：創建1個目錄kafka-offset-console
[cluster@PCS101 ~]$ mkdir kafka-offset-console [cluster@PCS101 ~]$ mkdir kafka-offset-console/logs [cluster@PCS101 ~]$ ls kafka-offset-console
步驟二：將jar包上傳到kafka-offset-console目錄下
[cluster@PCS101 kafka-offset-console]$ ls KafkaOffsetMonitor-assembly-0.2.0.jar logs
步驟三：創建一個啟動腳本
#!/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 134.32.123.101:2181,134.32.123.102:2181,134.32.123.103:2181 \ --port 8086 \ --refresh 10.seconds \ --retain 7.days 1>logs/stdout.log 2>logs/stderr.log &
啟動查看日志：
[cluster@PCS101 kafka-offset-console]$ sh ./startkoc.sh [cluster@PCS101 logs]$ tail -50f stdout.log serving resources from: jar:file:/home/cluster/kafka-offset-console/KafkaOffsetMonitor-assembly-0.2.0.jar!/offsetapp
訪問：http://134.32.123.101:8086/
Lag標識未消費消息數量。
topic：創建時topic名稱
partition：分區編號
offset：表示該parition已經消費了多少條message
logSize：表示該partition已經寫了多少條message
Lag：表示有多少條message沒有被消費。
Owner：表示消費者
Created：該partition創建時間
Last Seen：消費狀態刷新最新時間。
參考：
https://www.cnblogs.com/smartloli/p/4562551.html
https://www.cnblogs.com/yinchengzhe/p/5123515.html
https://www.cnblogs.com/dadonggg/p/8242682.html
https://blog.csdn.net/lizhitao/article/details/27199863