diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java index 4ce483c8ef705..8c03f432fba84 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java @@ -1045,7 +1045,7 @@ private CompletableFuture> getTopicPoliciesBypassSystemT final ServiceConfiguration serviceConfiguration = pulsar.getConfiguration(); if (serviceConfiguration.isSystemTopicEnabled() && serviceConfiguration.isTopicLevelPoliciesEnabled() && !NamespaceService.isSystemServiceNamespace(topicName.getNamespace()) - && !SystemTopicNames.isTopicPoliciesSystemTopic(topicName.toString())) { + && !EventsTopicNames.isTopicPoliciesSystemTopic(topicName.toString())) { return pulsar.getTopicPoliciesService().getTopicPoliciesAsync(topicName); } else { return CompletableFuture.completedFuture(Optional.empty());