public void advanceTime(final Duration advance) {
        if (advance.isNegative()) {
            throw new IllegalArgumentException("advance must be positive");
        }
        currentTime = currentTime.plus(advance);
    }
Advances the internally tracked event time of this input topic.
Each time a record without explicitly defined timestamp is piped,
the current topic event time is used as record timestamp.
<p>
Note: advancing the event time on the input topic, does not advance the tracked stream time in
{@link TopologyTestDriver} as long as no new input records are piped.
Furthermore, it does not advance the wall-clock time of {@link TopologyTestDriver}.

@param advance the duration of time to advance
streams/test-utils/src/main/java/org/apache/kafka/streams/TestInputTopic.java