@Override
    public void close() throws InterruptedException {
        beginShutdown("KafkaEventQueue#close");
        eventHandlerThread.join();
        log.info("closed event queue.");
    }
True if the event handler thread was interrupted. Protected by the lock.
server-common/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java