This is an automated email from the ASF dual-hosted git repository. guangning pushed a commit to branch branch-2.5 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit eaa8febcd928e140e03276bb43d4ec5e2e7b1745 Author: k2la <[email protected]> AuthorDate: Tue Jan 7 10:37:42 2020 +0900 add_backlogSize_in_topicStat (#5914) --- .../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 3a749f1..bbcf2dd 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 @@ -1432,7 +1432,8 @@ public class PersistentTopic extends AbstractTopic implements Topic, AddEntryCal topicStatsStream.writePair("msgRateOut", topicStatsHelper.aggMsgRateOut); topicStatsStream.writePair("msgThroughputIn", topicStatsHelper.aggMsgThroughputIn); topicStatsStream.writePair("msgThroughputOut", topicStatsHelper.aggMsgThroughputOut); - topicStatsStream.writePair("storageSize", ledger.getEstimatedBacklogSize()); + topicStatsStream.writePair("storageSize", ledger.getTotalSize()); + topicStatsStream.writePair("backlogSize", ledger.getEstimatedBacklogSize()); topicStatsStream.writePair("pendingAddEntriesCount", ((ManagedLedgerImpl) ledger).getPendingAddEntriesCount()); nsStats.msgRateIn += topicStatsHelper.aggMsgRateIn;
