| Interface | Description |
|---|---|
| Processor<KIn,VIn,KOut,VOut> |
A processor of key-value pair records.
|
| ProcessorContext<KForward,VForward> |
Processor context interface.
|
| ProcessorSupplier<KIn,VIn,KOut,VOut> |
A processor supplier that can create one or more
Processor instances. |
| RecordMetadata |
| Class | Description |
|---|---|
| ContextualProcessor<KIn,VIn,KOut,VOut> |
An abstract implementation of
Processor that manages the ProcessorContext instance and provides default no-op
implementation of Processor.close(). |
| Record<K,V> |
A data class representing an incoming record for processing in a
Processor
or a record to forward to downstream processors via ProcessorContext. |