From 6fd0cbcc0094a4533c68033f7914093d609205fd Mon Sep 17 00:00:00 2001 From: shixiaoxiao Date: Thu, 13 Jun 2024 21:02:27 +0800 Subject: [PATCH] fix get push consumer consumer rt --- consumer/statistics.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consumer/statistics.go b/consumer/statistics.go index b5d5f523..19e0f3b6 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) }