@Override
    public Cancellable schedule(final Duration interval,
                                final PunctuationType type,
                                final Punctuator callback) {
        final CapturedPunctuator capturedPunctuator = new CapturedPunctuator(interval, type, callback);

        punctuators.add(capturedPunctuator);

        return capturedPunctuator::cancel;
    }
The context exposes these metadata for use in the processor. Normally, they are set by the Kafka Streams framework,
but for the purpose of driving unit tests, you can set them directly.

@param topic     A topic name
@param partition A partition number
@param offset    A record offset
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/api/MockProcessorContext.java