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 ab719252f8c1e..34cad879e6631 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 @@ -1442,7 +1442,8 @@ public void updateRates(NamespaceStats nsStats, NamespaceBundleStats bundleStats 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;