This is an automated email from the ASF dual-hosted git repository.
maixiaohai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git
The following commit(s) were added to refs/heads/master by this push:
new 2361651 make exporter collect right putMessageSizeTotal for broker
(#84)
2361651 is described below
commit 2361651afb07502379ff35c8332c2b9a6b55c66b
Author: cserwen <[email protected]>
AuthorDate: Wed Jan 5 23:27:11 2022 +0800
make exporter collect right putMessageSizeTotal for broker (#84)
---
.../org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java
b/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java
index 4463111..ae87541 100644
---
a/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java
+++
b/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java
@@ -890,7 +890,7 @@ public class RMQMetricsCollector extends Collector {
clusterName, brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
- stats.getBrokerVersion()),
stats.getQueryThreadPoolQueueCapacity());
+ stats.getBrokerVersion()), stats.getPutMessageSizeTotal());
brokerRuntimeDispatchBehindBytes.put(new BrokerRuntimeMetric(
clusterName, brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
