Package org.apache.kafka.streams.processor

Interface Punctuator

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface Punctuator

A functional interface used as an argument to ProcessingContext.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(Record) or ProcessorContext.forward(Record), there won't be any record metadata. If ProcessorContext.forward(Record) is used, it's also not possible to set records headers.

Parameters:

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