activeBrokers = availableActiveBrokers.get(LOADBALANCE_BROKERS_ROOT) | activeBrokers = loadReports.listLocks(LOADBALANCE_BROKERS_ROOT).join() | availableActiveBrokers.get(LOADBALANCE_BROKERS_ROOT) | loadReports.listLocks(LOADBALANCE_BROKERS_ROOT).join() | pulsar | 1579b0f12533686f3b16f5e88aabda85c7f07d65 | org.apache.pulsar.broker.loadbalance.impl.SimpleLoadManagerImpl | | _1 | activeBrokers |
---|
_2 | activeBrokers |
---|
| v0 | LOADBALANCE_BROKERS_ROOT |
---|
| | v0 | LOADBALANCE_BROKERS_ROOT |
---|
| AssignedTo | False |