@Override
        public V putIfAbsent(final K key,
                             final V value) {
            return getValueOrNull(inner.putIfAbsent(key, ValueAndTimestamp.make(value, ConsumerRecord.NO_TIMESTAMP)));
        }
Close the driver, its topology, and all processors.
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java