public KafkaFuture<Node> controller() {
        return controller;
    }
Returns a future which yields the current controller id.
Note that this may yield null, if the controller ID is not yet known.
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterResult.java