@Override
        public void sleep(final long ms) {
            if (ms < 0) {
                throw new IllegalArgumentException("Sleep ms cannot be negative.");
            }
            timeMs.addAndGet(ms);
            highResTimeNs.addAndGet(TimeUnit.MILLISECONDS.toNanos(ms));
        }
Close the driver, its topology, and all processors.
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java