From 7e50b6f4a54a06682d15fdbe6a90c94a0277f088 Mon Sep 17 00:00:00 2001
From: maxlisongsong <maxlisongsong@didiglobal.com>
Date: Fri, 17 Jul 2026 00:08:08 +0800
Subject: [PATCH] [fix][broker] Log exception in
 PulsarMetadataEventSynchronizer failure path

---
 .../broker/service/PulsarMetadataEventSynchronizer.java  | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarMetadataEventSynchronizer.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarMetadataEventSynchronizer.java
index 3ca2dd5ca0a6c..b7c5982a5f560 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarMetadataEventSynchronizer.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarMetadataEventSynchronizer.java
@@ -226,7 +226,8 @@ private void startConsumer() {
                                     log.warn()
                                             .attr("messageId", msg.getMessageId())
                                             .attr("topic", topicName)
-                                            .log("Failed to synchronize for");
+                                            .exception(ex)
+                                            .log("Failed to synchronize metadata event");
                                     return null;
                                 });
                     } else {
@@ -237,7 +238,8 @@ private void startConsumer() {
                                     log.warn()
                                             .attr("messageId", msg.getMessageId())
                                             .attr("topic", topicName)
-                                            .log("Failed to synchronize for");
+                                            .exception(ex)
+                                            .log("Failed to synchronize metadata event");
                                     return null;
                                 });
                     }
@@ -245,7 +247,8 @@ private void startConsumer() {
                     log.warn()
                             .attr("messageId", msg.getMessageId())
                             .attr("topic", topicName)
-                            .log("Failed to synchronize for");
+                            .exception(e)
+                            .log("Failed to synchronize metadata event");
                 }
             });
         consumerBuilder.subscribeAsync().thenAccept(consumer -> {