public void handleCloseFetchSessionFailure(final Node fetchTarget,
                                               final FetchSessionHandler.FetchRequestData data,
                                               final Throwable t) {
        int sessionId = data.metadata().sessionId();
        removePendingFetchRequest(fetchTarget, sessionId);
        log.debug("Unable to send a close message for fetch session: {} to node: {}. " +
                "This may result in unnecessary fetch sessions at the broker.", sessionId, fetchTarget, t);
    }
Implements the core logic for a failed fetch response.

@param fetchTarget {@link Node} from which the fetch data was requested
@param data        {@link FetchSessionHandler.FetchRequestData} from request
@param t           {@link Throwable} representing the error that resulted in the failure
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java