簡(jiǎn)介

KafkaOffsetMonitor是由Kafka開(kāi)源社區(qū)提供的一款Web管理界面，用來(lái)實(shí)時(shí)監(jiān)控Kafka的Consumer以及Partition中的Offset，可以在web界面直觀的看到每個(gè)Partition的Message的增長(zhǎng)速度，是否消費(fèi)，是否阻塞等。

使用

如果不想編譯，可以直接去下個(gè)jar包

下載地址

寫(xiě)個(gè)腳本

vim kafkaOffsetMoniter.sh nohup java -cp KafkaOffsetMonitor-assembly-0.2.0-2.jar \ com.quantifind.kafka.offsetapp.OffsetGetterWeb \ --zk zk1:2181,zk2:2181,zk3:2181 \ --port 8089 \ --refresh 10.seconds \ --retain 1.days &

啟動(dòng)腳本

sh kafkaOffsetMoniter.sh

常用參數(shù)說(shuō)明

• –zk - Zookeeper hosts
• –port - 啟動(dòng)webUI的端口號(hào)
• –refresh - 頁(yè)面數(shù)據(jù)刷新時(shí)間
• –retain - 歷史數(shù)據(jù)存放的時(shí)間（存放在SQLlite中）

運(yùn)行界面

Topic信息

參數(shù)說(shuō)明

• Topic - Topic名稱(chēng)
• Partition - 分區(qū)編號(hào)
• Offset - 該partition消費(fèi)的消息
• logSize - 該partition所有的消息
• Lag - 未被消費(fèi)的消息數(shù)量
• Owner - 消費(fèi)者
• Created - partition創(chuàng)建時(shí)間
• Last Seen - 最后一次消費(fèi)時(shí)間

消息消費(fèi)圖

集群

轉(zhuǎn)載于:https://www.cnblogs.com/xiaomaohai/p/6158054.html

總結(jié)

以上是生活随笔為你收集整理的kafka监控工具kafkaOffsetMoniter的使用的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。