rocketmq-commits mailing list archives

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