[improve][broker] Add logs to getInternalStats for quickly locate p…

…roblem when schema ledger is lost (apache#22233)
streamnative · Mar 11, 2024 · b4f710d · b4f710d
1 parent c36c18d
commit b4f710d
Showing 1 changed file with 2 additions and 0 deletions.
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
@@ -2665,6 +2665,8 @@ public CompletableFuture<PersistentTopicInternalStats> getInternalStats(boolean
                                     stats.schemaLedgers.add(schemaLedgerInfo);
                                     completableFuture.complete(null);
                                 }).exceptionally(e -> {
+                                    log.error("[{}] Failed to get ledger metadata for the schema ledger {}",
+                                            topic, ledgerId, e);
                                     completableFuture.completeExceptionally(e);
                                     return null;
                                 });