public void onFailure(final long currentTimeMs, final RuntimeException e) {
            this.responseCompletionTimeMs = currentTimeMs;
            if (e != null) {
                this.future.completeExceptionally(e);
            } else {
                this.future.completeExceptionally(DisconnectException.INSTANCE);
            }
        }
Check if the code is disconnected and unavailable for immediate reconnection (i.e. if it is in reconnect
backoff window following the disconnect).
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java