[rocketmq-exporter] 06/33: Fix consumer offset repeated calc (#269)

[vongosling]

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 <easyforg...@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();
                     }
                 }
             }