private void fireFailure() {
        RuntimeException exception = exception();
        while (true) {
            RequestFutureListener<T> listener = listeners.poll();
            if (listener == null)
                break;
            listener.onFailure(exception);
        }
    }
Raise an error. The request will be marked as failed.
@param error corresponding error to be passed to caller
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFuture.java