K- the type of keys
V- the type of values
@InterfaceStability.Evolving public interface Processor<K,V>
|Modifier and Type||Method and Description|
Close this processor and clean up any resources.
Initialize this processor with the given context.
Process the record with the given key and value.
void init(ProcessorContext context)
context- the context; may not be null
key- the key for the record
value- the value for the record
@Deprecated void punctuate(long timestamp)
Punctuatorfunctional interface instead.
schedule itselfwith the context during
timestamp- the stream time when this method is being called
close()is called after an internal cleanup. Thus, it is not possible to write anything to Kafka as underlying clients are already closed.
Note: Do not close any streams managed resources, like
StateStores here, as they are managed by the library.