@Override
            void handleResponse(AbstractResponse response) {
                final AutomqGetNodesResponse resp = (AutomqGetNodesResponse) response;
                if (resp.data().errorCode() == Errors.NONE.code()) {
                    future.complete(createResult(resp));
                } else {
                    future.completeExceptionally(Errors.forCode(resp.data().errorCode()).exception());
                }
            }
Returns the broker id pertaining to the given resource, or null if the resource is not associated
with a particular broker.
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java