private void ensureActive() {
        if (!active())
            throw new DisconnectException("NetworkClient is no longer active, state is " + state);
    }
Interrupt the client if it is blocked waiting on I/O.
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java