public List<BrokerRegistration> getActiveBrokers() {
        return brokerRegistrations.values().stream()
            .filter(b -> isActive(b.id()))
            .collect(Collectors.toList());
    }
Determines the default directory for new partitions placed on a given broker.
metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java