You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rd...@apache.org on 2020/12/14 22:25:38 UTC
[pulsar] branch master updated: [pulsar-broker] capture stats with
precise backlog (#8928)
This is an automated email from the ASF dual-hosted git repository.
rdhabalia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new a7f692f [pulsar-broker] capture stats with precise backlog (#8928)
a7f692f is described below
commit a7f692f981ddf2f86a69809867797f7269196884
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>
---
.../org/apache/pulsar/broker/service/persistent/PersistentTopic.java | 2 +-
1 file changed, 1 insertion(+), 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 f957532..07af718 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
@@ -1537,7 +1537,7 @@ public class PersistentTopic extends AbstractTopic
// Populate subscription specific stats here
topicStatsStream.writePair("msgBacklog",
- subscription.getNumberOfEntriesInBacklog(false));
+ subscription.getNumberOfEntriesInBacklog(true));
topicStatsStream.writePair("msgRateExpired", subscription.getExpiredMessageRate());
topicStatsStream.writePair("msgRateOut", subMsgRateOut);
topicStatsStream.writePair("msgThroughputOut", subMsgThroughputOut);