This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 35049645986c10b2521a8cbf4de0e950ea9836ae Author: Rahul <[email protected]> AuthorDate: Wed Apr 22 16:43:50 2026 +0530 [fix][broker] pulsar admin stats internal with metadata command (#25557) Co-authored-by: Rahul Prasad <[email protected]> (cherry picked from commit 9cf1cc9b5bf5d5581fe4e40318b85dfdd2ec77f7) --- .../org/apache/pulsar/broker/service/persistent/PersistentTopic.java | 5 ++++- 1 file changed, 4 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 cb7157314c0..91264a8f7c3 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 @@ -3029,6 +3029,9 @@ public class PersistentTopic extends AbstractTopic implements Topic, AddEntryCal info.ledgerId = compactedTopicContext.getLedger().getId(); info.entries = compactedTopicContext.getLedger().getLastAddConfirmed() + 1; info.size = compactedTopicContext.getLedger().getLength(); + if (includeLedgerMetadata) { + info.metadata = compactedTopicContext.getLedger().getLedgerMetadata().toSafeString(); + } } stats.compactedLedger = info; @@ -3110,7 +3113,7 @@ public class PersistentTopic extends AbstractTopic implements Topic, AddEntryCal schemaLedgerInfo.entries = metadata.getLastEntryId() + 1; schemaLedgerInfo.size = metadata.getLength(); if (includeLedgerMetadata) { - info.metadata = metadata.toSafeString(); + schemaLedgerInfo.metadata = metadata.toSafeString(); } stats.schemaLedgers.add(schemaLedgerInfo); completableFuture.complete(null);
