[improve][broker] log exception in MessageDeduplication#takeSnapshot (a…

…pache#22994) Co-authored-by: fanjianye <[email protected]>
poorbarcode · Jul 9, 2024 · b473a7b · b473a7b
1 parent 9626e7e
commit b473a7b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...roker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java b/...roker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java
@@ -470,7 +470,8 @@ public void markDeleteComplete(Object ctx) {
 
             @Override
             public void markDeleteFailed(ManagedLedgerException exception, Object ctx) {
-                log.warn("[{}] Failed to store new deduplication snapshot at {}", topic.getName(), position);
+                log.warn("[{}] Failed to store new deduplication snapshot at {}",
+                        topic.getName(), position, exception);
                 snapshotTaking.set(false);
                 future.completeExceptionally(exception);
             }