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.

void punctuate(long timestamp)

punctuate is used exclusively when ProcessorNode is requested to execute a Punctuator.

Punctuator is scheduled (registered) using ProcessorContext.schedule method.

results matching ""

    No results matching ""