This is an automated email from the ASF dual-hosted git repository. vongosling pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git
commit ad60f293df419f586b285fd90b2ea6876ffbaea4 Merge: e788a8c d5cb076 Author: breezecoolyang <[email protected]> AuthorDate: Mon Jul 22 17:17:51 2019 +0800 Merge branch 'master' into master .github/ISSUE_TEMPLATE/bug_report.md | 38 ++ .github/ISSUE_TEMPLATE/feature_request.md | 20 + .github/PULL_REQUEST_TEMPLATE.md | 20 + CONTRIBUTING.md | 31 ++ README.md | 428 ++++++++++----------- src/main/docker/Dockerfile | 4 +- .../exporter/RocketMQExporterApplication.java | 2 - .../exporter/aspect/admin/MQAdminAspect.java | 2 +- .../exporter/service/RMQMetricsService.java | 4 +- .../rocketmq/exporter/task/MetricsCollectTask.java | 18 +- .../apache/rocketmq/exporter/util/JsonUtil.java | 2 +- .../exporter/util/{Mix.java => Utils.java} | 10 +- src/main/resources/application.properties | 2 +- 13 files changed, 344 insertions(+), 237 deletions(-) diff --cc README.md index f97a09b,2d116dc..df34c82 --- a/README.md +++ b/README.md @@@ -1,215 -1,210 +1,215 @@@ --RocketMQ_exporter --============== -- --RocketMQ exporter for Prometheus. -- --Table of Contents ------------------- --- [Compatibility](#compatibility) --- [Dependency](#dependency) --- [Download](#download) --- [Compile](#compile) -- - [Build Binary](#build-binary) -- - [Build Docker Image](#build-docker-image) --- [Run](#run) -- - [Run Binary](#run-binary) -- - [Run Docker Image](#run-docker-image) --- [Flags](#flags) --- [Metrics](#metrics) -- - [Brokers](#brokers) -- - [Topics](#topics) -- - [Consumer Groups](#consumer-groups) --- [Grafana Dashboard](#Grafana-Dashboard) - - [Use Example](#Use-Example) -- --Compatibility --------------- -- --Support [Apache RocketMQ](https://rocketmq.apache.org) version 4.3.2 (and later). -- --Dependency ------------ -- --- [Prometheus](https://prometheus.io) -- --Compile --------- -- --### Build Binary -- --```shell --mvn clean install --``` -- --### Build Docker Image -- --```shell --mvn package -Dmaven.test.skip=true docker:build --``` -- --Run ----- -- --### Run Binary -- --```shell - java -jar rocketmq-exporter-0.0.1-SNAPSHOT.jar [--rocketmq.config.namesrvAddr="127.0.0.1:9876" ...] -java -jar rocketmq-exporter-0.0.1-SNAPSHOT.jar --``` -- --### Run Docker Image -- --``` - docker container run -itd --rm -p 5557:5557 breezecoolyang/rocketmq-exporter [--rocketmq.config.namesrvAddr="127.0.0.1:9876" ...] -docker container run -itd --rm -p 5557:5557 docker.io/rocketmq-exporter --``` -- --Flags ----- -- --This image is configurable using different flags -- --|Flag name | Default | Description | --| -----------------------------------|--------------------|----------------------------------------------------| --| `rocketmq.config.namesrvAddr` | 127.0.0.1:9876 |name server address for broker cluster | --| `rocketmq.config.webTelemetryPath` | /metrics |Path under which to expose metrics | --| `server.port` | 5557 |Address to listen on for web interface and telemetry| --| `rocketmq.config.rocketmqVersion` | V4_3_2 |rocketmq broker version | -- --Metrics --------- -- --Documents about exposed Prometheus metrics. -- --### Broker -- --**Metrics details** -- --| Name | Exposed information | --| ------------ | ---------------------------------------------------- | --| `rocketmq_broker_tps` | Broker produces the number of messages per second | --| `rocketmq_broker_qps` | Broker consumes messages per second | -- --**Metrics output example** -- --```txt --# HELP rocketmq_broker_tps BrokerPutNums --# TYPE rocketmq_broker_tps gauge --rocketmq_broker_tps{cluster="MQCluster",broker="broker-a",} 7.0 --rocketmq_broker_tps{cluster="MQCluster",broker="broker-b",} 7.0 --# HELP rocketmq_broker_qps BrokerGetNums --# TYPE rocketmq_broker_qps gauge --rocketmq_broker_qps{cluster="MQCluster",broker="broker-a",} 8.0 --rocketmq_broker_qps{cluster="MQCluster",broker="broker-b",} 8.0 --``` -- --### Topics -- --**Metrics details** -- --| Name | Exposed information | --| ------------------- | -------------------------------------------------- | --| `rocketmq_producer_tps` | The number of messages produced per second per topic | --| `rocketmq_producer_message_size` | The size of a message produced per second by a topic (in bytes) | --| `rocketmq_producer_offset` | The progress of a topic's production message | -- --**Metrics output example** -- --```txt --# HELP rocketmq_producer_tps TopicPutNums --# TYPE rocketmq_producer_tps gauge --rocketmq_producer_tps{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",} 7.0 --rocketmq_producer_tps{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",} 7.0 --# HELP rocketmq_producer_message_size TopicPutMessageSize --# TYPE rocketmq_producer_message_size gauge --rocketmq_producer_message_size{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",} 1642.0 --rocketmq_producer_message_size{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",} 1638.0 --# HELP rocketmq_producer_offset TopicOffset --# TYPE rocketmq_producer_offset counter --rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="TBW102",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="DEV_TID_tfq",} 1878633.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="DEV_TID_tfq",} 3843787.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="DEV_TID_20190304",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="BenchmarkTest",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="DEV_TID_20190305",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="MQCluster",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",} 2798195.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="BenchmarkTest",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",} 1459666.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="MQCluster",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="SELF_TEST_TOPIC",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="OFFSET_MOVED_EVENT",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="broker-b",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="broker-a",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="SELF_TEST_TOPIC",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="RMQ_SYS_TRANS_HALF_TOPIC",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="DEV_TID_20190305",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="OFFSET_MOVED_EVENT",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="RMQ_SYS_TRANS_HALF_TOPIC",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="TBW102",} 0.0 --rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="DEV_TID_20190304",} 0.0 -- --``` -- --### Consumer Groups -- --**Metrics details** -- --| Name | Exposed information | --| ------------------------------------------------------------ | ------------------------------------------------------------ | --| `rocketmq_consumer_tps` | The number of messages consumed per second by a consumer group | --| `rocketmq_consumer_message_size` | The size of the message consumed by the consumer group per second (in bytes) | --| `rocketmq_consumer_offset` | Progress of consumption message for a consumer group | --| `rocketmq_group_get_latency` | Consumer latency on some topic for one queue | --| `rocketmq_group_get_latency_by_storetime ` | Consumption delay time of a consumer group | - | 消息堆积量（需要通过proSQL聚合）（rocketmq_producer_offset-rocketmq_consumer_offset） | Message accumulation (sum(rocketmq_producer_offset) by (topic) - on(topic) group_right sum(rocketmq_consumer_offset) by (group,topic)) | -| `rocketmq_message_accumulation`| How far Consumer offset lag behind | -- --**Metrics output example** -- --```txt --# HELP rocketmq_consumer_tps GroupGetNums --# TYPE rocketmq_consumer_tps gauge --rocketmq_consumer_tps{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 7.0 --rocketmq_consumer_tps{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 7.0 --# HELP rocketmq_consumer_message_size GroupGetMessageSize --# TYPE rocketmq_consumer_message_size gauge --rocketmq_consumer_message_size{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 1638.0 --rocketmq_consumer_message_size{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 1642.0 --# HELP rocketmq_consumer_offset GroupOffset --# TYPE rocketmq_consumer_offset counter --rocketmq_consumer_offset{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 1462030.0 --rocketmq_consumer_offset{cluster="MQCluster",broker="broker-a",topic="DEV_TID_tfq",group="DEV_CID_cfq",} 3843787.0 --rocketmq_consumer_offset{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 2800569.0 --rocketmq_consumer_offset{cluster="MQCluster",broker="broker-b",topic="DEV_TID_tfq",group="DEV_CID_cfq",} 1878633.0 --# HELP rocketmq_group_get_latency GroupGetLatency --# TYPE rocketmq_group_get_latency gauge --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="0",} 0.05 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="1",} 0.0 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="7",} 0.05 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="6",} 0.01 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="3",} 0.0 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="7",} 0.03 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="4",} 0.0 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="5",} 0.03 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="6",} 0.01 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="2",} 0.0 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="3",} 0.0 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="0",} 0.0 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="4",} 0.0 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="1",} 0.03 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="5",} 0.0 --rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="2",} 0.0 --# HELP rocketmq_group_get_latency_by_storetime GroupGetLatencyByStoreTime --# TYPE rocketmq_group_get_latency_by_storetime gauge --rocketmq_group_get_latency_by_storetime{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 3215.0 --rocketmq_group_get_latency_by_storetime{cluster="MQCluster",broker="broker-a",topic="DEV_TID_tfq",group="DEV_CID_cfq",} 0.0 --rocketmq_group_get_latency_by_storetime{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 3232.0 --rocketmq_group_get_latency_by_storetime{cluster="MQCluster",broker="broker-b",topic="DEV_TID_tfq",group="DEV_CID_cfq",} 0.0 --``` -- --Grafana Dashboard --------- --Grafana Dashboard ID: 10477, name: RocketMQ Exporter Overview. - For details of the dashboard please see [RocketMQ Exporter Overview](https://grafana.com/dashboards/10477). - - Use Example - ------------- -For details of the dashboard please see [RocketMQ Exporter Overview](https://grafana.com/dashboards/10477). ++RocketMQ_exporter ++============== ++ ++RocketMQ exporter for Prometheus. ++ ++Table of Contents ++----------------- ++- [Compatibility](#compatibility) ++- [Dependency](#dependency) ++- [Download](#download) ++- [Compile](#compile) ++ - [Build Binary](#build-binary) ++ - [Build Docker Image](#build-docker-image) ++- [Run](#run) ++ - [Run Binary](#run-binary) ++ - [Run Docker Image](#run-docker-image) ++- [Flags](#flags) ++- [Metrics](#metrics) ++ - [Brokers](#brokers) ++ - [Topics](#topics) ++ - [Consumer Groups](#consumer-groups) ++- [Grafana Dashboard](#Grafana-Dashboard) ++- [Use Example](#Use-Example) ++ ++Compatibility ++------------- ++ ++Support [Apache RocketMQ](https://rocketmq.apache.org) version 4.3.2 (and later). ++ ++Dependency ++---------- ++ ++- [Prometheus](https://prometheus.io) ++ ++Compile ++------- ++ ++### Build Binary ++ ++```shell ++mvn clean install ++``` ++ ++### Build Docker Image ++ ++```shell ++mvn package -Dmaven.test.skip=true docker:build ++``` ++ ++Run ++--- ++ ++### Run Binary ++ ++```shell ++java -jar rocketmq-exporter-0.0.1-SNAPSHOT.jar ++``` ++ ++### Run Docker Image ++ ++``` ++docker container run -itd --rm -p 5557:5557 docker.io/rocketmq-exporter ++``` ++ ++Flags ++--- ++ ++This image is configurable using different flags ++ ++|Flag name | Default | Description | ++| -----------------------------------|--------------------|----------------------------------------------------| ++| `rocketmq.config.namesrvAddr` | 127.0.0.1:9876 |name server address for broker cluster | ++| `rocketmq.config.webTelemetryPath` | /metrics |Path under which to expose metrics | ++| `server.port` | 5557 |Address to listen on for web interface and telemetry| ++| `rocketmq.config.rocketmqVersion` | V4_3_2 |rocketmq broker version | ++ ++Metrics ++------- ++ ++Documents about exposed Prometheus metrics. ++ ++### Broker ++ ++**Metrics details** ++ ++| Name | Exposed information | ++| ------------ | ---------------------------------------------------- | ++| `rocketmq_broker_tps` | Broker produces the number of messages per second | ++| `rocketmq_broker_qps` | Broker consumes messages per second | ++ ++**Metrics output example** ++ ++```txt ++# HELP rocketmq_broker_tps BrokerPutNums ++# TYPE rocketmq_broker_tps gauge ++rocketmq_broker_tps{cluster="MQCluster",broker="broker-a",} 7.0 ++rocketmq_broker_tps{cluster="MQCluster",broker="broker-b",} 7.0 ++# HELP rocketmq_broker_qps BrokerGetNums ++# TYPE rocketmq_broker_qps gauge ++rocketmq_broker_qps{cluster="MQCluster",broker="broker-a",} 8.0 ++rocketmq_broker_qps{cluster="MQCluster",broker="broker-b",} 8.0 ++``` ++ ++### Topics ++ ++**Metrics details** ++ ++| Name | Exposed information | ++| ------------------- | -------------------------------------------------- | ++| `rocketmq_producer_tps` | The number of messages produced per second per topic | ++| `rocketmq_producer_message_size` | The size of a message produced per second by a topic (in bytes) | ++| `rocketmq_producer_offset` | The progress of a topic's production message | ++ ++**Metrics output example** ++ ++```txt ++# HELP rocketmq_producer_tps TopicPutNums ++# TYPE rocketmq_producer_tps gauge ++rocketmq_producer_tps{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",} 7.0 ++rocketmq_producer_tps{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",} 7.0 ++# HELP rocketmq_producer_message_size TopicPutMessageSize ++# TYPE rocketmq_producer_message_size gauge ++rocketmq_producer_message_size{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",} 1642.0 ++rocketmq_producer_message_size{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",} 1638.0 ++# HELP rocketmq_producer_offset TopicOffset ++# TYPE rocketmq_producer_offset counter ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="TBW102",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="DEV_TID_tfq",} 1878633.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="DEV_TID_tfq",} 3843787.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="DEV_TID_20190304",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="BenchmarkTest",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="DEV_TID_20190305",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="MQCluster",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",} 2798195.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="BenchmarkTest",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",} 1459666.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="MQCluster",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="SELF_TEST_TOPIC",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="OFFSET_MOVED_EVENT",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="broker-b",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="broker-a",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="SELF_TEST_TOPIC",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="RMQ_SYS_TRANS_HALF_TOPIC",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="DEV_TID_20190305",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="OFFSET_MOVED_EVENT",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="RMQ_SYS_TRANS_HALF_TOPIC",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-b",topic="TBW102",} 0.0 ++rocketmq_producer_offset{cluster="MQCluster",broker="broker-a",topic="DEV_TID_20190304",} 0.0 ++ ++``` ++ ++### Consumer Groups ++ ++**Metrics details** ++ ++| Name | Exposed information | ++| ------------------------------------------------------------ | ------------------------------------------------------------ | ++| `rocketmq_consumer_tps` | The number of messages consumed per second by a consumer group | ++| `rocketmq_consumer_message_size` | The size of the message consumed by the consumer group per second (in bytes) | ++| `rocketmq_consumer_offset` | Progress of consumption message for a consumer group | ++| `rocketmq_group_get_latency` | Consumer latency on some topic for one queue | ++| `rocketmq_group_get_latency_by_storetime ` | Consumption delay time of a consumer group | ++| `rocketmq_message_accumulation`| How far Consumer offset lag behind | ++ ++**Metrics output example** ++ ++```txt ++# HELP rocketmq_consumer_tps GroupGetNums ++# TYPE rocketmq_consumer_tps gauge ++rocketmq_consumer_tps{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 7.0 ++rocketmq_consumer_tps{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 7.0 ++# HELP rocketmq_consumer_message_size GroupGetMessageSize ++# TYPE rocketmq_consumer_message_size gauge ++rocketmq_consumer_message_size{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 1638.0 ++rocketmq_consumer_message_size{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 1642.0 ++# HELP rocketmq_consumer_offset GroupOffset ++# TYPE rocketmq_consumer_offset counter ++rocketmq_consumer_offset{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 1462030.0 ++rocketmq_consumer_offset{cluster="MQCluster",broker="broker-a",topic="DEV_TID_tfq",group="DEV_CID_cfq",} 3843787.0 ++rocketmq_consumer_offset{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 2800569.0 ++rocketmq_consumer_offset{cluster="MQCluster",broker="broker-b",topic="DEV_TID_tfq",group="DEV_CID_cfq",} 1878633.0 ++# HELP rocketmq_group_get_latency GroupGetLatency ++# TYPE rocketmq_group_get_latency gauge ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="0",} 0.05 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="1",} 0.0 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="7",} 0.05 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="6",} 0.01 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="3",} 0.0 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="7",} 0.03 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="4",} 0.0 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="5",} 0.03 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="6",} 0.01 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="2",} 0.0 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="3",} 0.0 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="0",} 0.0 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="4",} 0.0 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="1",} 0.03 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="5",} 0.0 ++rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="2",} 0.0 ++# HELP rocketmq_group_get_latency_by_storetime GroupGetLatencyByStoreTime ++# TYPE rocketmq_group_get_latency_by_storetime gauge ++rocketmq_group_get_latency_by_storetime{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 3215.0 ++rocketmq_group_get_latency_by_storetime{cluster="MQCluster",broker="broker-a",topic="DEV_TID_tfq",group="DEV_CID_cfq",} 0.0 ++rocketmq_group_get_latency_by_storetime{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 3232.0 ++rocketmq_group_get_latency_by_storetime{cluster="MQCluster",broker="broker-b",topic="DEV_TID_tfq",group="DEV_CID_cfq",} 0.0 ++``` ++ ++Grafana Dashboard ++------- ++Grafana Dashboard ID: 10477, name: RocketMQ Exporter Overview. ++For details of the dashboard please see [RocketMQ Exporter Overview](https://grafana.com/dashboards/10477). ++ ++Use Example ++------------- +For details of the use example please refer to [use example](./rocketmq_exporter_use_example.md)
