@Override
        public boolean hasNext() {
            if (time != null) time.sleep(1);
            return iterator.hasNext();
        }
Install 2 publishers and check that the publishers that were installed are closed when the
loader is closed.
metadata/src/test/java/org/apache/kafka/image/loader/MetadataLoaderTest.java