[improve] [broker] make system topic distribute evenly. (apache#22953)

(cherry picked from commit 263c694) (cherry picked from commit 2c1fb16)
datastax · Jul 1, 2024 · c404e19 · c404e19
1 parent 659896e
commit c404e19
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...roker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java b/...roker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java
@@ -907,7 +907,9 @@ Optional<String> selectBroker(final ServiceUnitId serviceUnit) {
                     brokerToNamespaceToBundleRange, brokerToFailureDomainMap);
 
             // distribute bundles evenly to candidate-brokers if enable
-            if (conf.isLoadBalancerDistributeBundlesEvenlyEnabled()) {
+            // or system-namespace bundles
+            if (conf.isLoadBalancerDistributeBundlesEvenlyEnabled()
+                    || serviceUnit.getNamespaceObject().equals(NamespaceName.SYSTEM_NAMESPACE)) {
                 LoadManagerShared.removeMostServicingBrokersForNamespace(bundle,
                         brokerCandidateCache,
                         brokerToNamespaceToBundleRange);