kafka-streams-Punctuator.adoc

Punctuator — Contract for Scheduled Periodic Actions

Punctuator is the contract to perform a scheduled periodic action (aka punctuate) on a record stream.

package org.apache.kafka.streams.processor;

interface Punctuator {
  void punctuate(long timestamp);
}

Table 1. Punctuator Contract

Method	Description
punctuate	Used exclusively when ProcessorNode is requested to punctuate.

Punctuator can be scheduled (registered) on a ProcessorContext.