@Override
    public void close() throws InterruptedException {
        eventQueue.beginShutdown("close");
        log.debug("Closing SnapshotGenerator.");
        eventQueue.close();
    }
The time at which we created the last snapshot.
metadata/src/main/java/org/apache/kafka/image/publisher/SnapshotGenerator.java