[pulsar] branch master updated: [improve][broker] Support setting forceDeleteTenantAllowed dynamically (#18192)

[technoboy]

This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 1c78e0aabf5 [improve][broker] Support setting forceDeleteTenantAllowed 
dynamically (#18192)
1c78e0aabf5 is described below

commit 1c78e0aabf576145c5f7831e931d89ae795bc2cc
Author: Jiwei Guo <techno...@apache.org>
AuthorDate: Thu Oct 27 09:49:37 2022 +0800

    [improve][broker] Support setting forceDeleteTenantAllowed dynamically 
(#18192)
---
 .../java/org/apache/pulsar/broker/ServiceConfiguration.java  |  1 +
 .../org/apache/pulsar/broker/service/BrokerServiceTest.java  | 12 ++++++++++++
 2 files changed, 13 insertions(+)

diff --git 
a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
 
b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
index f0725353dd7..95c1a763d4e 100644
--- 
a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
+++ 
b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
@@ -643,6 +643,7 @@ public class ServiceConfiguration implements 
PulsarConfiguration {
 
     @FieldContext(
             category = CATEGORY_POLICIES,
+            dynamic = true,
             doc = "Allow forced deletion of tenants. Default is false."
     )
     private boolean forceDeleteTenantAllowed = false;
diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceTest.java
index eb9447b47fe..24e38438c53 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceTest.java
@@ -1508,4 +1508,16 @@ public class BrokerServiceTest extends BrokerTestBase {
             assertTrue(conf.isForceDeleteNamespaceAllowed());
         });
     }
+
+    @Test
+    public void testDynamicConfigurationsForceDeleteTenantAllowed() throws 
Exception {
+        cleanup();
+        conf.setForceDeleteTenantAllowed(false);
+        setup();
+        admin.brokers()
+                .updateDynamicConfiguration("forceDeleteTenantAllowed", 
"true");
+        Awaitility.await().untilAsserted(()->{
+            assertTrue(conf.isForceDeleteTenantAllowed());
+        });
+    }
 }