Punctuator
is the abstraction that Kafka Streams developers use to execute scheduled periodic actions (aka punctuate) on a record stream.
void punctuate(long timestamp)
punctuate
is used exclusively when ProcessorNode
is requested to execute a Punctuator.
Punctuator
is scheduled (registered) using ProcessorContext.schedule method.