(rocketmq-client-go) branch master updated: fix get push consumer consumer rt (#1148)

[yuzhou]

This is an automated email from the ASF dual-hosted git repository.

yuzhou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git


The following commit(s) were added to refs/heads/master by this push:
     new fe4b42e  fix get push consumer consumer rt (#1148)
fe4b42e is described below

commit fe4b42e2f62e708d0496decc0ea5240baa35ec0d
Author: SHI <34100836+woaishixiaox...@users.noreply.github.com>
AuthorDate: Wed Sep 4 15:38:52 2024 +0800

    fix get push consumer consumer rt (#1148)
    
    Co-authored-by: shixiaoxiao <shixiaox...@bytedance.com>
---
 consumer/statistics.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/consumer/statistics.go b/consumer/statistics.go
index b5d5f52..19e0f3b 100644
--- a/consumer/statistics.go
+++ b/consumer/statistics.go
@@ -119,7 +119,7 @@ func (mgr *StatsManager) getPullTPS(group, topic string) 
statsSnapshot {
 }
 
 func (mgr *StatsManager) getConsumeRT(group, topic string) statsSnapshot {
-       ss := mgr.topicAndGroupPullRT.getStatsDataInMinute(topic + "@" + group)
+       ss := mgr.topicAndGroupConsumeRT.getStatsDataInMinute(topic + "@" + 
group)
        if ss.sum == 0 {
                return mgr.topicAndGroupConsumeRT.getStatsDataInHour(topic + 
"@" + group)
        }