public interface Punctuator
ProcessorContext.schedule(Duration, PunctuationType, Punctuator).
void punctuate(long timestamp)
Furthermore, for any record that is sent downstream via
won't be any record metadata. If
ProcessorContext.forward(Object, Object) is used,
it's also not possible to set records headers.
timestamp- when the operation is being called, depending on