K- the type of keys
V- the type of values
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 can be used to access topology and record meta data, to
schedule a method to be
called periodically and to access attached
context- the context; may not be null
void process(K key, V value)
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.