@Override
    public void initiateClose() {
        if (state.compareAndSet(State.ACTIVE, State.CLOSING)) {
            wakeup();
        }
    }
Interrupt the client if it is blocked waiting on I/O.
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java