[rocketmq-exporter] branch master updated: fix: filter group_diff for boardcast (#80)

[maixiaohai]

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 f2abea0  fix: filter group_diff for boardcast (#80)
f2abea0 is described below

commit f2abea08ee4fe18a1257f4d0fbf92d63e935651c
Author: qsrg <42698388+q...@users.noreply.github.com>
AuthorDate: Sun Dec 26 12:03:08 2021 +0800

    fix: filter group_diff for boardcast (#80)
    
    Co-authored-by: 青衫如故 <568071...@qq.com>
---
 src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java 
b/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java
index fd910b9..8d7739c 100644
--- a/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java
+++ b/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java
@@ -295,6 +295,7 @@ public class MetricsCollectTask {
                     log.warn(String.format("no any offset for consumer(%s), 
topic(%s), ignore this", group, topic));
                     continue;
                 }
+                if (messageModel == MessageModel.CLUSTERING)
                 {
                     diff = consumeStats.computeTotalDiff();
                     consumeTPS = consumeStats.getConsumeTps();