public BrokerHeartbeatManager getHeartbeatManager() {
        return heartbeatManager;
    }
Determines the default directory for new partitions placed on a given broker.
metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java