@Override
        public void onFailure(RuntimeException e, RequestFuture<Void> future) {
            log.debug("FindCoordinator request failed due to {}", e.toString());

            if (!(e instanceof RetriableException)) {
                // Remember the exception if fatal so we can ensure it gets thrown by the main thread
                fatalFindCoordinatorException = e;
            }

            super.onFailure(e, future);
        }
Discover the current coordinator for the group. Sends a FindCoordinator request to
the given broker node. The returned future should be polled to get the result of the request.
@return A request future which indicates the completion of the metadata request
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java