KafkaOffsetMonitor如何安裝部署

這篇文章將為大家詳細(xì)講解有關(guān)KafkaOffsetMonitor如何安裝部署，小編覺得挺實(shí)用的，因此分享給大家做個(gè)參考，希望大家閱讀完這篇文章后可以有所收獲。

KafkaOffsetMonitor功能：

1.從標(biāo)題都可以看出來，Kafka Offset Monitor，是對consumer消費(fèi)情況進(jìn)行監(jiān)控,并能列出每            個(gè)consumer offset,滯后數(shù)據(jù)。

2.消費(fèi)者組列表

3.每個(gè)topic的所有parition列表(topic,pid,offset,logSize,lag,owner)

4.查看topic的歷史消費(fèi)信息.

1下載

　　在安裝KafkaOffsetMonitor管理平臺時(shí)，我們需要先下載其安裝包，其資源可以在Github上找到

2安裝部署

　　KafkaOffsetMonitor的安裝部署較為簡單，所有的資源都打包到一個(gè)JAR文件中了，因此，直接運(yùn)行即可，省去了我們?nèi)ヅ渲?。這里我們可以新建一個(gè)目錄單獨(dú)用于Kafka的監(jiān)控目錄，我這里新建一個(gè)kafka_monitor文件目錄，然后我們在準(zhǔn)備啟動腳本，腳本內(nèi)容如下所示：

#! /bin/bash

java -cp KafkaOffsetMonitor-assembly-0.2.0.jar \

 com.quantifind.kafka.offsetapp.OffsetGetterWeb \

 --zk ZookeeperAddress \

 --port 8089 \

 --refresh 10.seconds \

 --retain 1.days

　　給大家解釋以下這條啟動命令的含義，首先我們需要指明運(yùn)行Web監(jiān)控的類，然后需要用到ZooKeeper，所有要填寫ZK集群信息，接著是Web運(yùn)行端口，頁面數(shù)據(jù)刷新的時(shí)間以及保留數(shù)據(jù)的時(shí)間值。

3、啟動

　　啟動步驟如下所示：

• 步驟1:啟動ZK   zkServer.sh start

• 步驟2:啟動Kafka服務(wù)（集群依次輸入以下命令啟動）

           ./kafka-server-start.sh config/server.properties &

• 步驟3:啟動Web監(jiān)控服務(wù)

java -cp KafkaOffsetMonitor-assembly-0.2.0.jar \

 com.quantifind.kafka.offsetapp.OffsetGetterWeb \

 --zk dn1:2181,dn2:2181,dn3:2181 \

 --port 8089 \

 --refresh 10.seconds \

 --retain 1.days

　　Web服務(wù)啟動成功后，如下圖所示：

4.KafkaOffsetMonitor運(yùn)行預(yù)覽

　　下面，我們來使用Kafka代碼生產(chǎn)消費(fèi)一些消息，使用Web監(jiān)控來瀏覽消息情況。這里直接預(yù)覽演示結(jié)果，如下圖所示：

5.總結(jié)

　　在運(yùn)行KafkaOffsetMonitor的JAR包時(shí)，需要確保啟動參數(shù)的配置正確，以免啟動出錯(cuò)，另外，Github的上的KafkaOffsetMonitor的JAR中的靜態(tài)資源有些鏈接用到了Google的超鏈接，所有如果直接只用，若本地木有代理軟件會啟動出錯(cuò)，這里使用我所提供的JAR，這個(gè)JAR是經(jīng)過靜態(tài)資源改版后重新編譯的使用本地靜態(tài)資源。

　　另外圖中的一些參數(shù)的含義如下：

• Topic：創(chuàng)建Topic名稱

• Partition：分區(qū)編號

• Offset：表示該P(yáng)arition已經(jīng)消費(fèi)了多少M(fèi)essage

• LogSize：表示該P(yáng)artition生產(chǎn)了多少M(fèi)essage

• Lag：表示有多少條Message未被消費(fèi)

• Owner：表示消費(fèi)者

• Created：表示該P(yáng)artition創(chuàng)建時(shí)間

• Last Seen：表示消費(fèi)狀態(tài)刷新最新時(shí)間

關(guān)于“KafkaOffsetMonitor如何安裝部署”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，使各位可以學(xué)到更多知識，如果覺得文章不錯(cuò)，請把它分享出去讓更多的人看到。