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
index b94048c4a5e07..1f8d06571908e 100644
--- 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,