public void poll(final long timeoutMs, final long currentTimeMs) {
        trySend(currentTimeMs);

        long pollTimeoutMs = timeoutMs;
        if (!unsentRequests.isEmpty()) {
            pollTimeoutMs = Math.min(retryBackoffMs, pollTimeoutMs);
        }
        this.client.poll(pollTimeoutMs, currentTimeMs);
        maybePropagateMetadataError();
        checkDisconnects(currentTimeMs);
    }
Returns the responses of the sent requests. This method will try to send the unsent requests, poll for responses,
and check the disconnected nodes.

@param timeoutMs     timeout time
@param currentTimeMs current time
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java