[pulsar] branch branch-2.11 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.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git


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

commit e0d0b2b4fa8c256228cd4ef690e891f2c39924ae
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 02e1e8e184b..2fba83bd901 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
@@ -157,6 +157,8 @@ public class SubscriptionStatsImpl implements 
SubscriptionStats {
         bytesOutCounter = 0;
         msgOutCounter = 0;
         msgRateRedeliver = 0;
+        messageAckRate = 0;
+        chunkedMessageRate = 0;
         msgBacklog = 0;
         backlogSize = 0;
         msgBacklogNoDelayed = 0;
@@ -186,6 +188,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;