[improve][broker]Reuse method getAvailableBrokersAsync (apache#23099)

(cherry picked from commit 2add3ab)
datastax · Aug 8, 2024 · 1a87104 · 1a87104
1 parent 70964e0
commit 1a87104
Showing 1 changed file with 1 addition and 2 deletions.
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
@@ -366,8 +366,7 @@ private void reapDeadBrokerPreallocations(List<String> aliveBrokers) {
     @Override
     public Set<String> getAvailableBrokers() {
         try {
-            return new HashSet<>(brokersData.listLocks(LoadManager.LOADBALANCE_BROKERS_ROOT)
-                    .get(conf.getMetadataStoreOperationTimeoutSeconds(), TimeUnit.SECONDS));
+            return getAvailableBrokersAsync().get(conf.getMetadataStoreOperationTimeoutSeconds(), TimeUnit.SECONDS);
         } catch (Exception e) {
             log.warn("Error when trying to get active brokers", e);
             return loadData.getBrokerData().keySet();