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

lhotari pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit 846e718977763bea3a0d50677f49ec79f1fd8ea8
Author: fengyubiao <[email protected]>
AuthorDate: Sat Aug 17 17:55:37 2024 +0800

    [improve] [broker] Optimize performance for checking max topics when the 
topic is a system topic (#23185)
    
    (cherry picked from commit 73433cd06e65ce5e194372a657c5a414e820138b)
---
 .../src/main/java/org/apache/pulsar/broker/service/BrokerService.java  | 3 +++
 1 file changed, 3 insertions(+)

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 a36af85836b..4c6d2ec4c5a 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
@@ -3682,6 +3682,9 @@ public class BrokerService implements Closeable {
     }
 
     private CompletableFuture<Void> checkMaxTopicsPerNamespace(TopicName 
topicName, int numPartitions) {
+        if (isSystemTopic(topicName)) {
+            return CompletableFuture.completedFuture(null);
+        }
         return pulsar.getPulsarResources().getNamespaceResources()
                 .getPoliciesAsync(topicName.getNamespaceObject())
                 .thenCompose(optPolicies -> {

Reply via email to