commit 02ef916eb61bd1886a509326dd1e247797f56260
author Sip <easyforgood@hotmail.com> Tue May 07 11:48:12 2019 +0800
committer vongosling <vongosling@apache.org> Mon Jun 03 18:54:48 2019 +0800
tree 78e45576b39549ea98a6d8fe400fb708b66e95ff
parent c936cfec50716f242981e7af00668da3d5adfa1d

Fix consumer offset repeated calc (#269)

rocketmq-prometheus-exporter/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java

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 @@
                         for (Map.Entry<String, Long> consumeOffsetEntry : consumeOffsetEntries) {
                             metricsService.getCollector().AddGroupOffsetMetric(clusterName,consumeOffsetEntry.getKey(), topic, group, consumeOffsetEntry.getValue());
                         }
+                        consumeOffsetMap.clear();
                     }
                 }
             }