@Override
        public WindowStoreIterator<V> fetch(final K key,
                                            final long timeFrom,
                                            final long timeTo) {
            return fetch(key, Instant.ofEpochMilli(timeFrom), Instant.ofEpochMilli(timeTo));
        }
Close the driver, its topology, and all processors.
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java