public boolean awaitDone(long timeout, TimeUnit unit) throws InterruptedException {
        return completedLatch.await(timeout, unit);
    }
Check whether the response is ready to be handled
@return true if the response is ready, false otherwise
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFuture.java