fix

apache · Apr 16, 2024 · 29d3798 · 29d3798
1 parent d4bbab8
commit 29d3798
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
@@ -3178,7 +3178,7 @@ protected void internalGetBacklogSizeByMessageId(AsyncResponse asyncResponse,
             } else {
                 return CompletableFuture.completedFuture(null);
             }
-        }).thenAccept(__ -> validateTopicOwnershipAsync(topicName, authoritative)
+        }).thenCompose(__ -> validateTopicOwnershipAsync(topicName, authoritative))
         .thenCompose(unused -> getTopicReferenceAsync(topicName))
         .thenAccept(t -> {
             PersistentTopic topic = (PersistentTopic) t;
@@ -3204,7 +3204,7 @@ protected void internalGetBacklogSizeByMessageId(AsyncResponse asyncResponse,
             }
             resumeAsyncResponseExceptionally(asyncResponse, ex);
             return null;
-        }));
+        });
     }
 
     protected CompletableFuture<Void> internalSetBacklogQuota(BacklogQuota.BacklogQuotaType backlogQuotaType,