Package org.apache.kafka.streams.processor

Interface Punctuator

public interface Punctuator

A functional interface used as an argument to ProcessorContext.schedule(Duration, PunctuationType, Punctuator).

See Also:

• Cancellable

Method Summary

Modifier and Type	Method	Description
void	punctuate(long timestamp)	Perform the scheduled periodic operation.

Method Details

punctuate

void punctuate(long timestamp)

Perform the scheduled periodic operation.

If this method accesses ProcessorContext or ProcessorContext, record metadata like topic, partition, and offset or RecordMetadata won't be available.

Furthermore, for any record that is sent downstream via ProcessorContext.forward(Object, Object) or ProcessorContext.forward(Record), there won't be any record metadata. If ProcessorContext.forward(Object, Object) is used, it's also not possible to set records headers.

Parameters:

timestamp - when the operation is being called, depending on PunctuationType