You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vo...@apache.org on 2019/07/05 07:43:13 UTC
[rocketmq-exporter] 06/19: Fix consumer offset repeated calc (#269)
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 02ef916eb61bd1886a509326dd1e247797f56260
Author: Sip <ea...@hotmail.com>
AuthorDate: Tue May 7 11:48:12 2019 +0800
Fix consumer offset repeated calc (#269)
---
.../main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java b/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java
index 504ac88..3f359e9 100644
--- a/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java
+++ b/rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java
@@ -122,6 +122,7 @@ public class MetricsCollectTask {
for (Map.Entry<String, Long> consumeOffsetEntry : consumeOffsetEntries) {
metricsService.getCollector().AddGroupOffsetMetric(clusterName,consumeOffsetEntry.getKey(), topic, group, consumeOffsetEntry.getValue());
}
+ consumeOffsetMap.clear();
}
}
}