@Override
    public boolean active() {
        return state.get() == State.ACTIVE;
    }
Interrupt the client if it is blocked waiting on I/O.
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java