Skip to content

Commit 69c9bd8

Browse files
committed
[feat][broker] follow up apache#23637 to avoid exception thrown
1 parent 429f7de commit 69c9bd8

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java

+8-8
Original file line numberDiff line numberDiff line change
@@ -38,13 +38,7 @@
3838
import org.apache.pulsar.client.admin.RevokeTopicPermissionOptions;
3939
import org.apache.pulsar.common.naming.NamespaceName;
4040
import org.apache.pulsar.common.naming.TopicName;
41-
import org.apache.pulsar.common.policies.data.AuthAction;
42-
import org.apache.pulsar.common.policies.data.AuthPolicies;
43-
import org.apache.pulsar.common.policies.data.NamespaceOperation;
44-
import org.apache.pulsar.common.policies.data.PolicyName;
45-
import org.apache.pulsar.common.policies.data.PolicyOperation;
46-
import org.apache.pulsar.common.policies.data.TenantOperation;
47-
import org.apache.pulsar.common.policies.data.TopicOperation;
41+
import org.apache.pulsar.common.policies.data.*;
4842
import org.apache.pulsar.common.util.FutureUtil;
4943
import org.apache.pulsar.common.util.RestException;
5044
import org.apache.pulsar.metadata.api.MetadataStoreException.NotFoundException;
@@ -690,12 +684,18 @@ public CompletableFuture<Boolean> allowTopicOperationAsync(TopicName topicName,
690684
});
691685
}
692686

687+
@Override
688+
public CompletableFuture<Boolean> allowBrokerOperationAsync(String clusterName, String brokerId,
689+
BrokerOperation brokerOperation, String role,
690+
AuthenticationDataSource authData) {
691+
}
692+
693693
@Override
694694
public CompletableFuture<Boolean> allowTopicPolicyOperationAsync(TopicName topicName, String role,
695695
PolicyName policyName,
696696
PolicyOperation policyOperation,
697697
AuthenticationDataSource authData) {
698-
return validateTenantAdminAccess(topicName.getTenant(), role, authData);
698+
return isSuperUser(role, authData, conf);
699699
}
700700

701701
public CompletableFuture<Boolean> validateTenantAdminAccess(String tenantName, String role,

0 commit comments

Comments
 (0)