[feat][broker] Implement allowBrokerOperationAsync in PulsarAuthoriza…

…tionProvider to avoid exception thrown (apache#23663)
ascentstream · Nov 29, 2024 · 4603722 · 4603722
1 parent 7fc88d6
commit 4603722
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/...mon/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java b/...mon/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java
@@ -40,6 +40,7 @@
 import org.apache.pulsar.common.naming.TopicName;
 import org.apache.pulsar.common.policies.data.AuthAction;
 import org.apache.pulsar.common.policies.data.AuthPolicies;
+import org.apache.pulsar.common.policies.data.BrokerOperation;
 import org.apache.pulsar.common.policies.data.NamespaceOperation;
 import org.apache.pulsar.common.policies.data.PolicyName;
 import org.apache.pulsar.common.policies.data.PolicyOperation;
@@ -690,6 +691,13 @@ public CompletableFuture<Boolean> allowTopicOperationAsync(TopicName topicName,
                 });
     }
 
+    @Override
+    public CompletableFuture<Boolean> allowBrokerOperationAsync(String clusterName, String brokerId,
+                                                                BrokerOperation brokerOperation, String role,
+                                                                AuthenticationDataSource authData) {
+        return isSuperUser(role, authData, conf);
+    }
+
     @Override
     public CompletableFuture<Boolean> allowTopicPolicyOperationAsync(TopicName topicName, String role,
                                                                      PolicyName policyName,