MRS 3.0.x獲取Kafka服務指標Java樣例

準備：運行樣例程序的機器需與MRS集群網絡連通

一. 運行樣例程序

1. 獲取集群浮動ip登錄集群master節點

登錄MRS集群Master節點，執行命令ip a | grep wsom，對應ip即為浮動ip。浮動ip可能綁定在任意maste節點或控制節點上，若某一節點沒獲取到，請切換到其他節點嘗試

2. 配置用戶。建議在mrs manager頁面創建單獨的用戶用于獲取監控指標，請參考：創建用戶

3. 下載附件中的代碼，在根目錄執行mvn clean package編譯，將target目錄下的mrs-cluster-metrics-1.0-jar-with-dependencies.jar拷貝到執行機器上。

4. 在執行機器上運行命令 java -jar mrs-cluster-metrics-1.0-jar-with-dependencies.jar {浮動ip} {用戶名} {用戶密碼} {服務名} {指標名}

例如：java -jar mrs-cluster-metrics-1.0-jar-with-dependencies.jar 172.0.0.2 admin YourPassWord Kafka bk_topic_bytesinpersec

獲取的指標直接輸出到console，例如：

二. 樣例程序說明

MRS Manger獲取監控指標為Http Restful接口，比較特別的點是調用接口前要先經過cas認證。

樣例代碼中Main類為入口類，大家可以從該類開始閱讀。

獲取監控指標接口是

GET /api/v2/clusters/{cluster_id}/services/{service_name}/metrics

接口說明如下：

查詢服務監控指標數據：該接口用與查詢指定集群的指定服務的監控指標數據。

權限：集群查看，集群管理

參數說明：

Response形如：

三. Kafka指標列表

四. 參考資料

參考Manager Rest登陸Demo

注：樣例代碼實現盡可能簡單易懂，實際應用中請根據業務進行改造。

附件： MRSClusterMonitorDemo.zip 29.09KB 下載次數：14次

Java Kafka MapReduce

版權聲明：本文內容由網絡用戶投稿，版權歸原作者所有，本站不擁有其著作權，亦不承擔相應法律責任。如果您發現本站中有涉嫌抄襲或描述失實的內容，請聯系我們jiasou666@gmail.com 處理，核實后本網站將在24小時內刪除侵權內容。

版權聲明：本文內容由網絡用戶投稿，版權歸原作者所有，本站不擁有其著作權，亦不承擔相應法律責任。如果您發現本站中有涉嫌抄襲或描述失實的內容，請聯系我們jiasou666@gmail.com 處理，核實后本網站將在24小時內刪除侵權內容。