public final void closeNow() {
            if (closed)
                throw new IllegalStateException("Attempt to close a channel that has already been closed");
            handleCloseOnAuthenticationFailure(channel);
            closed = true;
        }
Close the channel now, regardless of whether the delay has expired or not.
clients/src/main/java/org/apache/kafka/common/network/Selector.java