public void poll(RequestFuture<?> future) {
        while (!future.isDone())
            poll(time.timer(Long.MAX_VALUE), future);
    }
Block indefinitely until the given request future has finished.
@param future The request future to await.
@throws WakeupException if {@link #wakeup()} is called from another thread
@throws InterruptException if the calling thread is interrupted
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java