public void wakeup() {
        // wakeup should be safe without holding the client lock since it simply delegates to
        // Selector's wakeup, which is thread-safe
        log.debug("Received user wakeup");
        this.wakeup.set(true);
        this.client.wakeup();
    }
Wakeup an active poll. This will cause the polling thread to throw an exception either
on the current poll if one is active, or the next poll.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java