Kafka-Monitor


 

kafka Monitor

監測Kafka集群狀態
Topic、Consumer Group列表
圖形化展示 topic 和 consumer 之間的關系
圖形化展示 consumer 的 Offset、Lag 等信息

Kafka Offset Monitor

https://github.com/quantifind/KafkaOffsetMonitor
KafkaOffsetMonitor:程序一個jar包的形式運行,部署較為方便。只有監控功能,使用起來也較為安全。

執行格式:

java -cp KafkaOffsetMonitor-assembly-0.2.1.jar \
com.quantifind.kafka.offsetapp.OffsetGetterWeb \
--offsetStorage kafka \
--zk zk-server1,zk-server2 \
--port 8090 \
--refresh 10.seconds \
--retain 2.days

offsetStorage 目前只支持 kaka,zk 按照host1:port1,host2:port2… 的格式去寫即可;

port為開啟web界面的端口號

refresh為刷新時間

retain為數據保留時間(單位seconds, minutes, hours, days)

示例:

# cat start.sh
# !/bin/sh
echo "KafkaOffsetMonitor starting"
nohup java -cp KafkaOffsetMonitor-assembly-0.3.0.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --offsetStorage kafka --zk zoo1:2181,zoo2:2181,zoo3:2181 --port 8090 --refresh 10.seconds --retain 1.days > /dev/null 2>&1 &

正式線測試訪問:

http://17.16.1.45:8090/#/clusterviz


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM