You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2019/05/19 00:49:38 UTC
[pulsar] 23/26: Validate admin operation on topic with
authoritative parameter (#4270)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch branch-2.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 389bd1fd74c01a5793b79d86e4d6eb82248d40ac
Author: Like <ke...@outlook.com>
AuthorDate: Thu May 16 05:20:55 2019 +0800
Validate admin operation on topic with authoritative parameter (#4270)
---
.../java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java | 2 +-
1 file changed, 1 insertion(+), 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
index 962c0dc..b29eb9c 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
@@ -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();