@Override
    public void wakeup() {
        this.nioSelector.wakeup();
    }
Interrupt the nioSelector if it is blocked waiting to do I/O.
clients/src/main/java/org/apache/kafka/common/network/Selector.java