[improve][admin]Remove repeating validateTopicOwnershipAsync action (a…

…pache#18996) Co-authored-by: gavingaozhangmin <[email protected]>
yangl · Dec 21, 2022 · 3b09016 · 3b09016
1 parent 5ea6790
commit 3b09016
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -1537,7 +1537,7 @@ protected CompletableFuture<Void> internalDeleteSubscriptionAsync(String subName
             future = CompletableFuture.completedFuture(null);
         }
 
-        return future.thenCompose(__ -> validateTopicOwnershipAsync(topicName, authoritative)).thenCompose(__ -> {
+        return future.thenCompose(__ -> {
             if (topicName.isPartitioned()) {
                 return internalDeleteSubscriptionForNonPartitionedTopicAsync(subName, authoritative, force);
             } else {