MRS 3.0.x获取Kafka服务指标Java样例

网友投稿 630 2022-05-28

准备:运行样例程序的机器需与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} {用户名} {用户密码} {服务名} {指标名}

MRS 3.0.x获取Kafka服务指标Java样例

例如: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小时内删除侵权内容。

上一篇:2021华为云GaussDB年度大盘点,感恩有你
下一篇:Linux 性能监控和优化介绍
相关文章