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 -> {