localData = brokerDataCache.get(key).orElseThrow(KeeperException.NoNodeException::new) | localData = brokersData.readLock(key).get() | brokerDataCache.get(key).orElseThrow(KeeperException.NoNodeException::new) | brokersData.readLock(key).get() | pulsar | 1579b0f12533686f3b16f5e88aabda85c7f07d65 | org.apache.pulsar.broker.loadbalance.impl.ModularLoadManagerImpl | | | | | | AssignedTo | False |