You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2020/12/21 11:50:32 UTC
[pulsar] branch branch-2.6 updated: [pulsar-broker] capture stats
with precise backlog (#8928)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.6
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.6 by this push:
new a4ab408 [pulsar-broker] capture stats with precise backlog (#8928)
a4ab408 is described below
commit a4ab408c724ed69964169c8d470f1634c88b50d4
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 7d832d6..a9b1eec 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
@@ -1437,7 +1437,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);