public void handleError(Throwable t) {
        log.info("Error sending fetch request {} to node {}:", nextMetadata, node, t);
        nextMetadata = nextMetadata.nextCloseExistingAttemptNew();
    }
Handle an error sending the prepared request.

When a network error occurs, we close any existing fetch session on our next request,
and try to create a new session.

@param t     The exception.
clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java