Punctuator (kafka 3.0.2 API)

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