You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2022/07/21 12:32:20 UTC
[rocketmq-client-go] branch master updated: fix bug when get `mqadmin consumerStatus` can't get consume status. (#812)
This is an automated email from the ASF dual-hosted git repository.
dinglei 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 509d461 fix bug when get `mqadmin consumerStatus` can't get consume status. (#812)
509d461 is described below
commit 509d461b8b6706ef784c4456313bb9445cd3fb34
Author: WJL3333 <wa...@bytedance.com>
AuthorDate: Thu Jul 21 20:32:15 2022 +0800
fix bug when get `mqadmin consumerStatus` can't get consume status. (#812)
---
consumer/push_consumer.go | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
index 4ce8fa4..eb29a48 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -365,11 +365,11 @@ func (pc *pushConsumer) GetConsumerRunningInfo(stack bool) *internal.ConsumerRun
topic := key.(string)
info.SubscriptionData[value.(*internal.SubscriptionData)] = true
status := internal.ConsumeStatus{
- PullRT: pc.stat.getPullRT(topic, pc.consumerGroup).avgpt,
- PullTPS: pc.stat.getPullTPS(topic, pc.consumerGroup).tps,
- ConsumeRT: pc.stat.getConsumeRT(topic, pc.consumerGroup).avgpt,
- ConsumeOKTPS: pc.stat.getConsumeOKTPS(topic, pc.consumerGroup).tps,
- ConsumeFailedTPS: pc.stat.getConsumeFailedTPS(topic, pc.consumerGroup).tps,
+ PullRT: pc.stat.getPullRT(pc.consumerGroup, topic).avgpt,
+ PullTPS: pc.stat.getPullTPS(pc.consumerGroup, topic).tps,
+ ConsumeRT: pc.stat.getConsumeRT(pc.consumerGroup, topic).avgpt,
+ ConsumeOKTPS: pc.stat.getConsumeOKTPS(pc.consumerGroup, topic).tps,
+ ConsumeFailedTPS: pc.stat.getConsumeFailedTPS(pc.consumerGroup, topic).tps,
ConsumeFailedMsgs: pc.stat.topicAndGroupConsumeFailedTPS.getStatsDataInHour(topic + "@" + pc.consumerGroup).sum,
}
info.StatusTable[topic] = status