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)
close()will be called on it; the framework may later re-use the processor by calling
context- the context; may not be null
key- the key for the record
value- the value for the record
#close()is called after an internal cleanup. Thus, it is not possible to write anything to Kafka as underlying clients are already closed. The framework may later re-use this processor by calling
#init()on it again.
Note: Do not close any streams managed resources, like
StateStores here, as they are managed by the library.