private Queue<ProducerRecord<byte[], byte[]>> getRecordsQueue(final String topicName) {
        final Queue<ProducerRecord<byte[], byte[]>> outputRecords = outputRecordsByTopic.get(topicName);
        if (outputRecords == null && !processorTopology.sinkTopics().contains(topicName)) {
            log.warn("Unrecognized topic: {}, this can occur if dynamic routing is used and no output has been "
                         + "sent to this topic yet. If not using a TopicNameExtractor, check that the output topic "
                         + "is correct.", topicName);
        }
        return outputRecords;
    }
Advances the internally mocked wall-clock time.
This might trigger a {@link PunctuationType#WALL_CLOCK_TIME wall-clock} type
{@link ProcessorContext#schedule(Duration, PunctuationType, Punctuator) punctuations}.

@param advance the amount of time to advance wall-clock time
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java