public void advanceWallClockTime(final Duration advance) {
        Objects.requireNonNull(advance, "advance cannot be null");
        mockWallClockTime.sleep(advance.toMillis());
        if (task != null) {
            task.maybePunctuateSystemTime();
            commit(task.prepareCommit());
            task.postCommit(true);
        }
        completeAllProcessableWork();
    }
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