@Override
        public void register(final Set<TopicPartition> changelogPartitions, final ProcessorStateManager stateManager) {
            for (final TopicPartition changelogPartition : changelogPartitions) {
                register(changelogPartition, stateManager);
            }
        }
Close the driver, its topology, and all processors.
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java