KIn- the type of input keys
VIn- the type of input values
KOut- the type of output keys
VOut- the type of output values
public interface Processor<KIn,VIn,KOut,VOut>
|Modifier and Type||Method and Description|
Close this processor and clean up any resources.
Initialize this processor with the given context.
Process the record.
default void init(ProcessorContext<KOut,VOut> 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(Record<KIn,VIn> record)
record- the record to process
default void close()
#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.