(rocketmq) branch develop updated: [ISSUE #8885] Resolve the issue of inaccurate CK number statistics (#8886)

[dinglei]

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

dinglei pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 43f3c2b61b [ISSUE #8885] Resolve the issue of inaccurate CK number 
statistics (#8886)
43f3c2b61b is described below

commit 43f3c2b61bf5dbdb174c4664121677d66542277c
Author: rongtong <jinrongton...@mails.ucas.ac.cn>
AuthorDate: Wed Nov 6 10:15:42 2024 +0800

    [ISSUE #8885] Resolve the issue of inaccurate CK number statistics (#8886)
---
 .../java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
index 07bc0ac07b..fe8ccb03dc 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
@@ -815,6 +815,9 @@ public class PopMessageProcessor implements 
NettyRequestProcessor {
             ck.addDiff((int) (msgQueueOffset - offset));
         }
 
+        this.brokerController.getBrokerStatsManager().incBrokerCkNums(1);
+        
this.brokerController.getBrokerStatsManager().incGroupCkNums(requestHeader.getConsumerGroup(),
 requestHeader.getTopic(), 1);
+
         final boolean addBufferSuc = this.popBufferMergeService.addCk(
             ck, reviveQid, -1, getMessageTmpResult.getNextBeginOffset()
         );