@Override
    public void close() {
        log.debug("Node {}: closing.", nodeId);
        beginShutdown();

        try {
            eventQueue.close();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            throw new RuntimeException(e);
        }
    }
The current leader, as seen by this log manager.
metadata/src/test/java/org/apache/kafka/metalog/LocalLogManager.java