Validate admin operation on topic with authoritative parameter (#4270)

389bd1fd · Like · Matteo Merli · 20695e92 · 389bd1fd
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java ...apache/pulsar/broker/admin/impl/PersistentTopicsBase.java +1 -1

未找到文件。
--- 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
@@ -309,7 +309,7 @@ public class PersistentTopicsBase extends AdminResource {
    }

    protected void internalDeleteTopicForcefully(boolean authoritative) {
-        validateAdminOperationOnTopic(true);
+        validateAdminOperationOnTopic(authoritative);
        Topic topic = getTopicReference(topicName);
        try {
            topic.deleteForcefully().get();