You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zi...@apache.org on 2026/07/20 10:08:40 UTC
(pulsar) branch master updated: [fix][broker] Log exception in PulsarMetadataEventSynchronizer failure path (#26203)
This is an automated email from the ASF dual-hosted git repository.
nodece pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new f1650c5ab57b [fix][broker] Log exception in PulsarMetadataEventSynchronizer failure path (#26203)
f1650c5ab57b is described below
commit f1650c5ab57bb9742717852e2496ffcea0f6f7b9
Author: SongOf <46...@users.noreply.github.com>
AuthorDate: Mon Jul 20 18:08:34 2026 +0800
[fix][broker] Log exception in PulsarMetadataEventSynchronizer failure path (#26203)
Co-authored-by: maxlisongsong <ma...@didiglobal.com>
---
.../pulsar/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 3ca2dd5ca0a6..b7c5982a5f56 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 @@ public class PulsarMetadataEventSynchronizer implements MetadataEventSynchronize
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 @@ public class PulsarMetadataEventSynchronizer implements MetadataEventSynchronize
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 @@ public class PulsarMetadataEventSynchronizer implements MetadataEventSynchronize
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 -> {