[pulsar] branch branch-2.10 updated: [fix][broker] Fix getPartitionedStats miss subscription's messageAckRate (#19870)

[technoboy]

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

technoboy pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new f8dc8c10325 [fix][broker] Fix getPartitionedStats miss subscription's 
messageAckRate (#19870)
f8dc8c10325 is described below

commit f8dc8c10325be746c63f6b163354a2a715d2da4c
Author: WangJialing <65590138+wangjialing...@users.noreply.github.com>
AuthorDate: Sun Apr 23 10:07:02 2023 +0800

    [fix][broker] Fix getPartitionedStats miss subscription's messageAckRate 
(#19870)
---
 .../pulsar/common/policies/data/stats/SubscriptionStatsImpl.java      | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java
 
b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java
index 53112295aa2..ebe10050e99 100644
--- 
a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java
+++ 
b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java
@@ -142,6 +142,8 @@ public class SubscriptionStatsImpl implements 
SubscriptionStats {
         bytesOutCounter = 0;
         msgOutCounter = 0;
         msgRateRedeliver = 0;
+        messageAckRate = 0;
+        chunkedMessageRate = 0;
         msgBacklog = 0;
         backlogSize = 0;
         msgBacklogNoDelayed = 0;
@@ -166,6 +168,8 @@ public class SubscriptionStatsImpl implements 
SubscriptionStats {
         this.bytesOutCounter += stats.bytesOutCounter;
         this.msgOutCounter += stats.msgOutCounter;
         this.msgRateRedeliver += stats.msgRateRedeliver;
+        this.messageAckRate += stats.messageAckRate;
+        this.chunkedMessageRate += stats.chunkedMessageRate;
         this.msgBacklog += stats.msgBacklog;
         this.backlogSize += stats.backlogSize;
         this.msgBacklogNoDelayed += stats.msgBacklogNoDelayed;