[pulsar] 05/07: [pulsar-broker] capture stats with precise backlog (#8928)

[pe...@apache.org]

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

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

commit 40135da18063d59a3474aab7f97168ac7cd3af29
Author: Rajan Dhabalia <rd...@apache.org>
AuthorDate: Mon Dec 14 14:25:11 2020 -0800

    [pulsar-broker] capture stats with precise backlog (#8928)
    
    Co-authored-by: Sijie Guo <si...@apache.org>
    (cherry picked from commit a7f692f981ddf2f86a69809867797f7269196884)
---
 .../org/apache/pulsar/broker/service/persistent/PersistentTopic.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
index 486d2d7..00dcd81 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -1500,7 +1500,8 @@ public class PersistentTopic extends AbstractTopic implements Topic, AddEntryCal
                 topicStatsStream.endList();
 
                 // Populate subscription specific stats here
-                topicStatsStream.writePair("msgBacklog", subscription.getNumberOfEntriesInBacklog(false));
+                topicStatsStream.writePair("msgBacklog",
+                        subscription.getNumberOfEntriesInBacklog(true));
                 topicStatsStream.writePair("msgRateExpired", subscription.getExpiredMessageRate());
                 topicStatsStream.writePair("msgRateOut", subMsgRateOut);
                 topicStatsStream.writePair("msgThroughputOut", subMsgThroughputOut);