@SuppressWarnings({"WeakerAccess", "unused"})
        public PunctuationType getType() {
            return type;
        }
{@link CapturedPunctuator} holds captured punctuators, along with their scheduling information.
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java