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 <[email protected]>
AuthorDate: Wed Sep 4 15:38:52 2024 +0800
fix get push consumer consumer rt (#1148)
Co-authored-by: shixiaoxiao <[email protected]>
---
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)
}
