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 <rdhaba...@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);