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

注：样例代码实现尽可能简单易懂，实际应用中请根据业务进行改造。