1.概述
在《Kafka 消息監(jiān)控 - Kafka Eagle》一文中，簡單的介紹了 Kafka Eagle這款監(jiān)控工具的作用，截圖預(yù)覽，以及使用詳情。今天筆者通過其源碼來解讀實現(xiàn)細節(jié)。目前該項目已托管于 Github 之上，作者編寫了使用手冊，告知使用者如何安裝，部署，啟動該系統(tǒng)。但對于實現(xiàn)的細節(jié)并未在參考手冊中詳細指出。這里，筆者通過本篇博文，來詳細解讀其實現(xiàn)細節(jié)。相關(guān)資料文獻地址如下所示：
2.內(nèi)容
截止到版本 Kafka Eagle v1.1.1 支持監(jiān)控0.8.2.x（存放消費信息于Zookeeper）以及 0.10.x（存放消費信息于Kafka的topic中）。對于前者，從Zookeeper中獲取消息信息，難度不大，編寫Zookeeper客戶端實現(xiàn)代碼即可，該版本在Zookeeper下的存儲結(jié)構(gòu)樹如下圖所示：
對于實現(xiàn)細節(jié)，可使用ZkUtils工具類來獲取相關(guān)數(shù)據(jù)，以獲取消費信息為例，代碼如下所示：
延伸閱讀
學(xué)習(xí)是年輕人改變自己的最好方式