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_T
没有合适的资源?快使用搜索试试~ 我知道了~
rocketmq的可视化界面包
共2000个文件
js:1447个
java:284个
xml:74个
需积分: 0 0 下载量 4 浏览量
2024-04-22
12:40:58
上传
评论
收藏 5.96MB 7Z 举报
温馨提示
rocketmq的可视化界面包
资源推荐
资源详情
资源评论
收起资源包目录
rocketmq的可视化界面包 (2000个子文件)
angular-material.min.css 419KB
angular-material.min.css 419KB
bootstrap.css 151KB
bootstrap.css 151KB
bootstrap.min.css 122KB
bootstrap.min.css 122KB
bootstrap-material-design.css 108KB
bootstrap-material-design.css 108KB
bootstrap-material-design.css 97KB
bootstrap-material-design.css 97KB
bootstrap-material-design.min.css 92KB
bootstrap-material-design.min.css 92KB
btn.css 40KB
btn.css 40KB
font-awesome.css 39KB
font-awesome.css 39KB
font-awesome.min.css 30KB
font-awesome.min.css 30KB
bootstrap-theme.css 26KB
bootstrap-theme.css 26KB
docs.css 25KB
docs.css 25KB
bootstrap-theme.min.css 23KB
bootstrap-theme.min.css 23KB
chosen.css 14KB
chosen.css 14KB
ladda.css 12KB
ladda.css 12KB
main.css 11KB
main.css 11KB
ladda-themeless.css 10KB
ladda-themeless.css 10KB
normalize.css 10KB
normalize.css 10KB
ladda.min.css 9KB
ladda.min.css 9KB
bootstrap-datetimepicker.min.css 8KB
bootstrap-datetimepicker.min.css 8KB
ladda-themeless.min.css 8KB
ladda-themeless.min.css 8KB
default.css 6KB
default.css 6KB
app.css 5KB
app.css 5KB
ngDialog-theme-default.css 5KB
ngDialog-theme-default.css 5KB
timeline.css 3KB
timeline.css 3KB
jquery.dropdown.css 2KB
jquery.dropdown.css 2KB
angular-ui-notification.css 2KB
angular-ui-notification.css 2KB
angular-ui-notification.css 2KB
angular-ui-notification.css 2KB
normalize.css 2KB
normalize.css 2KB
theme.css 1KB
theme.css 1KB
ngDialog.min.css 1KB
ngDialog.min.css 1KB
ripples.css 1KB
ripples.css 1KB
ripples.min.css 1KB
ripples.min.css 1KB
ripples.css 798B
ripples.css 798B
animate.css 566B
animate.css 566B
chosen-spinner.css 493B
chosen-spinner.css 493B
angular-csp.css 364B
login.css 140B
login.css 140B
message_ext.h 6KB
producer.h 4KB
push_consumer.h 4KB
pull_consumer.h 4KB
message.h 4KB
consume_type.h 3KB
msg_listener.h 2KB
session_credentials.h 2KB
pull_result_iterator.h 2KB
message_queue.h 2KB
pull_status.h 2KB
pull_result.h 2KB
send_status.h 2KB
consume_status.h 1KB
send_result.h 1KB
common.h 1012B
topic.html 24KB
404.html 23KB
consumer.html 22KB
message.html 15KB
messageTrace.html 10KB
index.html 7KB
cluster.html 6KB
_header.html 3KB
producer.html 3KB
index.html 2KB
un_support_browser.html 2KB
共 2000 条
- 1
- 2
- 3
- 4
- 5
- 6
- 20
资源评论
玖六儿
- 粉丝: 195
- 资源: 2
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功