fix get push consumer consumer rt (#1148)

Co-authored-by: shixiaoxiao <[email protected]>
apache · Sep 4, 2024 · fe4b42e · fe4b42e
1 parent 98ee94d
commit fe4b42e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
 	}