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 43e8bd2ac16272731c93476ed1265454ca0921fc Author: vongosling <[email protected]> AuthorDate: Mon Jun 3 18:56:46 2019 +0800 Cherry pick from the external codes --- .../.gitignore => .gitignore | 0 rocketmq-prometheus-exporter/LICENSE => LICENSE | 0 README.md | 206 ++++++++++++++++++++- .../example.rules => example.rules | 0 rocketmq-prometheus-exporter/pom.xml => pom.xml | 0 rocketmq-prometheus-exporter/README.md | 204 -------------------- .../src => src}/main/docker/Dockerfile | 0 .../exporter/RocketMQExporterApplication.java | 0 .../exporter/aspect/admin/MQAdminAspect.java | 0 .../admin/annotation/MultiMQAdminCmdMethod.java | 0 .../exporter/collector/RMQMetricsCollector.java | 0 .../rocketmq/exporter/config/RMQConfigure.java | 0 .../exporter/controller/RMQMetricsController.java | 0 .../exporter/exception/ServiceException.java | 0 .../exporter/model/metrics/BrokerMetric.java | 0 .../exporter/model/metrics/ConsumerMetric.java | 0 .../model/metrics/ConsumerQueueMetric.java | 0 .../exporter/model/metrics/ProducerMetric.java | 0 .../exporter/service/AbstractCommonService.java | 0 .../exporter/service/RMQMetricsService.java | 0 .../exporter/service/client/MQAdminExtImpl.java | 0 .../exporter/service/client/MQAdminInstance.java | 0 .../service/impl/RMQMetricsServiceImpl.java | 0 .../rocketmq/exporter/task/MetricsCollectTask.java | 0 .../apache/rocketmq/exporter/util/JsonUtil.java | 0 .../main/resources/application.properties | 0 .../src => src}/main/resources/logback.xml | 0 .../style => style}/copyright/Apache.xml | 0 .../copyright/profiles_settings.xml | 0 .../style => style}/rmq_checkstyle.xml | 0 .../style => style}/rmq_codeStyle.xml | 0 31 files changed, 204 insertions(+), 206 deletions(-) diff --git a/rocketmq-prometheus-exporter/.gitignore b/.gitignore similarity index 100% rename from rocketmq-prometheus-exporter/.gitignore rename to .gitignore diff --git a/rocketmq-prometheus-exporter/LICENSE b/LICENSE similarity index 100% rename from rocketmq-prometheus-exporter/LICENSE rename to LICENSE diff --git a/README.md b/README.md index 6ae4e8f..c70f170 100644 --- a/README.md +++ b/README.md @@ -1,2 +1,204 @@ -## RocketMQ Exporter -[](https://www.apache.org/licenses/LICENSE-2.0.html) +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) +- [Contribute](#contribute) + +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" ...] +``` + +### Run Docker Image + +``` +docker container run -itd --rm -p 5557:5557 breezecoolyang/rocketmq-exporter [--rocketmq.config.namesrvAddr="127.0.0.1:9876" ...] +``` + +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` | total put message numbers per second for this broker | +| `rocketmq_broker_qps` | total get message numbers per second for this broker | + +**Metrics output example** + +```txt +# HELP rocketmq_broker_tps BrokerPutNums +# TYPE rocketmq_broker_tps gauge +rocketmq_broker_tps{cluster="MQCluster",broker="broker-a",} 7.933333333333334 +rocketmq_broker_tps{cluster="MQCluster",broker="broker-b",} 7.916666666666667 +# HELP rocketmq_broker_qps BrokerGetNums +# TYPE rocketmq_broker_qps gauge +rocketmq_broker_qps{cluster="MQCluster",broker="broker-a",} 8.2 +rocketmq_broker_qps{cluster="MQCluster",broker="broker-b",} 8.15 +``` + +### Topics + +**Metrics details** + +| Name | Exposed information | +| ------------------- | -------------------------------------------------- | +| `rocketmq_producer_tps` | sending messages number per second for this topic | +| `rocketmq_producer_put_size` | sending messages size per second for this topic | +| `rocketmq_producer_offset` | Current Offset of a Broker for this topic | + +**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.933333333333334 +rocketmq_producer_tps{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",} 7.916666666666667 +# HELP rocketmq_producer_put_size TopicPutSize +# TYPE rocketmq_producer_put_size gauge +rocketmq_producer_put_size{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",} 1642.2 +rocketmq_producer_put_size{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",} 1638.75 +# 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` | consumer message numbers per second for this Topic | +| `rocketmq_consumer_get_size` | consumer message size per second for this Topic | +| `rocketmq_consumer_offset` | consumer offset for this topic | +| `rocketmq_group_get_latency` | consumer latency on some topic for one queue | +| `rocketmq_group_get_latency_by_storetime ` | consumer latency between message consume time and message store time on some topic | + +**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.916666666666667 +rocketmq_consumer_tps{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 7.933333333333334 +# HELP rocketmq_consumer_get_size GroupGetSize +# TYPE rocketmq_consumer_get_size gauge +rocketmq_consumer_get_size{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 1638.75 +rocketmq_consumer_get_size{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 1642.2 +# 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.016666666666666666 +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.03333333333333333 +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.03333333333333333 +rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="6",} 0.016666666666666666 +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.03333333333333333 +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 +``` diff --git a/rocketmq-prometheus-exporter/example.rules b/example.rules similarity index 100% rename from rocketmq-prometheus-exporter/example.rules rename to example.rules diff --git a/rocketmq-prometheus-exporter/pom.xml b/pom.xml similarity index 100% rename from rocketmq-prometheus-exporter/pom.xml rename to pom.xml diff --git a/rocketmq-prometheus-exporter/README.md b/rocketmq-prometheus-exporter/README.md deleted file mode 100644 index c70f170..0000000 --- a/rocketmq-prometheus-exporter/README.md +++ /dev/null @@ -1,204 +0,0 @@ -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) -- [Contribute](#contribute) - -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" ...] -``` - -### Run Docker Image - -``` -docker container run -itd --rm -p 5557:5557 breezecoolyang/rocketmq-exporter [--rocketmq.config.namesrvAddr="127.0.0.1:9876" ...] -``` - -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` | total put message numbers per second for this broker | -| `rocketmq_broker_qps` | total get message numbers per second for this broker | - -**Metrics output example** - -```txt -# HELP rocketmq_broker_tps BrokerPutNums -# TYPE rocketmq_broker_tps gauge -rocketmq_broker_tps{cluster="MQCluster",broker="broker-a",} 7.933333333333334 -rocketmq_broker_tps{cluster="MQCluster",broker="broker-b",} 7.916666666666667 -# HELP rocketmq_broker_qps BrokerGetNums -# TYPE rocketmq_broker_qps gauge -rocketmq_broker_qps{cluster="MQCluster",broker="broker-a",} 8.2 -rocketmq_broker_qps{cluster="MQCluster",broker="broker-b",} 8.15 -``` - -### Topics - -**Metrics details** - -| Name | Exposed information | -| ------------------- | -------------------------------------------------- | -| `rocketmq_producer_tps` | sending messages number per second for this topic | -| `rocketmq_producer_put_size` | sending messages size per second for this topic | -| `rocketmq_producer_offset` | Current Offset of a Broker for this topic | - -**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.933333333333334 -rocketmq_producer_tps{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",} 7.916666666666667 -# HELP rocketmq_producer_put_size TopicPutSize -# TYPE rocketmq_producer_put_size gauge -rocketmq_producer_put_size{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",} 1642.2 -rocketmq_producer_put_size{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",} 1638.75 -# 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` | consumer message numbers per second for this Topic | -| `rocketmq_consumer_get_size` | consumer message size per second for this Topic | -| `rocketmq_consumer_offset` | consumer offset for this topic | -| `rocketmq_group_get_latency` | consumer latency on some topic for one queue | -| `rocketmq_group_get_latency_by_storetime ` | consumer latency between message consume time and message store time on some topic | - -**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.916666666666667 -rocketmq_consumer_tps{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 7.933333333333334 -# HELP rocketmq_consumer_get_size GroupGetSize -# TYPE rocketmq_consumer_get_size gauge -rocketmq_consumer_get_size{cluster="MQCluster",broker="broker-b",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 1638.75 -rocketmq_consumer_get_size{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",} 1642.2 -# 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.016666666666666666 -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.03333333333333333 -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.03333333333333333 -rocketmq_group_get_latency{cluster="MQCluster",broker="broker-a",topic="DEV_TID_topic_tfq",group="DEV_CID_consumer_cfq",queueid="6",} 0.016666666666666666 -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.03333333333333333 -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 -``` diff --git a/rocketmq-prometheus-exporter/src/main/docker/Dockerfile b/src/main/docker/Dockerfile similarity index 100% rename from rocketmq-prometheus-exporter/src/main/docker/Dockerfile rename to src/main/docker/Dockerfile diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/RocketMQExporterApplication.java b/src/main/java/org/apache/rocketmq/exporter/RocketMQExporterApplication.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/RocketMQExporterApplication.java rename to src/main/java/org/apache/rocketmq/exporter/RocketMQExporterApplication.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/aspect/admin/MQAdminAspect.java b/src/main/java/org/apache/rocketmq/exporter/aspect/admin/MQAdminAspect.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/aspect/admin/MQAdminAspect.java rename to src/main/java/org/apache/rocketmq/exporter/aspect/admin/MQAdminAspect.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/aspect/admin/annotation/MultiMQAdminCmdMethod.java b/src/main/java/org/apache/rocketmq/exporter/aspect/admin/annotation/MultiMQAdminCmdMethod.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/aspect/admin/annotation/MultiMQAdminCmdMethod.java rename to src/main/java/org/apache/rocketmq/exporter/aspect/admin/annotation/MultiMQAdminCmdMethod.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java b/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java rename to src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/config/RMQConfigure.java b/src/main/java/org/apache/rocketmq/exporter/config/RMQConfigure.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/config/RMQConfigure.java rename to src/main/java/org/apache/rocketmq/exporter/config/RMQConfigure.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/controller/RMQMetricsController.java b/src/main/java/org/apache/rocketmq/exporter/controller/RMQMetricsController.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/controller/RMQMetricsController.java rename to src/main/java/org/apache/rocketmq/exporter/controller/RMQMetricsController.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/exception/ServiceException.java b/src/main/java/org/apache/rocketmq/exporter/exception/ServiceException.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/exception/ServiceException.java rename to src/main/java/org/apache/rocketmq/exporter/exception/ServiceException.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/model/metrics/BrokerMetric.java b/src/main/java/org/apache/rocketmq/exporter/model/metrics/BrokerMetric.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/model/metrics/BrokerMetric.java rename to src/main/java/org/apache/rocketmq/exporter/model/metrics/BrokerMetric.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/model/metrics/ConsumerMetric.java b/src/main/java/org/apache/rocketmq/exporter/model/metrics/ConsumerMetric.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/model/metrics/ConsumerMetric.java rename to src/main/java/org/apache/rocketmq/exporter/model/metrics/ConsumerMetric.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/model/metrics/ConsumerQueueMetric.java b/src/main/java/org/apache/rocketmq/exporter/model/metrics/ConsumerQueueMetric.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/model/metrics/ConsumerQueueMetric.java rename to src/main/java/org/apache/rocketmq/exporter/model/metrics/ConsumerQueueMetric.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/model/metrics/ProducerMetric.java b/src/main/java/org/apache/rocketmq/exporter/model/metrics/ProducerMetric.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/model/metrics/ProducerMetric.java rename to src/main/java/org/apache/rocketmq/exporter/model/metrics/ProducerMetric.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/service/AbstractCommonService.java b/src/main/java/org/apache/rocketmq/exporter/service/AbstractCommonService.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/service/AbstractCommonService.java rename to src/main/java/org/apache/rocketmq/exporter/service/AbstractCommonService.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/service/RMQMetricsService.java b/src/main/java/org/apache/rocketmq/exporter/service/RMQMetricsService.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/service/RMQMetricsService.java rename to src/main/java/org/apache/rocketmq/exporter/service/RMQMetricsService.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/service/client/MQAdminExtImpl.java b/src/main/java/org/apache/rocketmq/exporter/service/client/MQAdminExtImpl.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/service/client/MQAdminExtImpl.java rename to src/main/java/org/apache/rocketmq/exporter/service/client/MQAdminExtImpl.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/service/client/MQAdminInstance.java b/src/main/java/org/apache/rocketmq/exporter/service/client/MQAdminInstance.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/service/client/MQAdminInstance.java rename to src/main/java/org/apache/rocketmq/exporter/service/client/MQAdminInstance.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/service/impl/RMQMetricsServiceImpl.java b/src/main/java/org/apache/rocketmq/exporter/service/impl/RMQMetricsServiceImpl.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/service/impl/RMQMetricsServiceImpl.java rename to src/main/java/org/apache/rocketmq/exporter/service/impl/RMQMetricsServiceImpl.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java b/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java rename to src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/util/JsonUtil.java b/src/main/java/org/apache/rocketmq/exporter/util/JsonUtil.java similarity index 100% rename from rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/util/JsonUtil.java rename to src/main/java/org/apache/rocketmq/exporter/util/JsonUtil.java diff --git a/rocketmq-prometheus-exporter/src/main/resources/application.properties b/src/main/resources/application.properties similarity index 100% rename from rocketmq-prometheus-exporter/src/main/resources/application.properties rename to src/main/resources/application.properties diff --git a/rocketmq-prometheus-exporter/src/main/resources/logback.xml b/src/main/resources/logback.xml similarity index 100% rename from rocketmq-prometheus-exporter/src/main/resources/logback.xml rename to src/main/resources/logback.xml diff --git a/rocketmq-prometheus-exporter/style/copyright/Apache.xml b/style/copyright/Apache.xml similarity index 100% rename from rocketmq-prometheus-exporter/style/copyright/Apache.xml rename to style/copyright/Apache.xml diff --git a/rocketmq-prometheus-exporter/style/copyright/profiles_settings.xml b/style/copyright/profiles_settings.xml similarity index 100% rename from rocketmq-prometheus-exporter/style/copyright/profiles_settings.xml rename to style/copyright/profiles_settings.xml diff --git a/rocketmq-prometheus-exporter/style/rmq_checkstyle.xml b/style/rmq_checkstyle.xml similarity index 100% rename from rocketmq-prometheus-exporter/style/rmq_checkstyle.xml rename to style/rmq_checkstyle.xml diff --git a/rocketmq-prometheus-exporter/style/rmq_codeStyle.xml b/style/rmq_codeStyle.xml similarity index 100% rename from rocketmq-prometheus-exporter/style/rmq_codeStyle.xml rename to style/rmq_codeStyle.xml
