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