Package org.apache.kafka.streams.processor.api

Interface Summary

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 Summary

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().
MockProcessorContext<KForward,VForward>	MockProcessorContext is a mock of ProcessorContext for users to test their Processor, Transformer, and ValueTransformer implementations.
MockProcessorContext.CapturedForward<K,V>
MockProcessorContext.CapturedPunctuator	MockProcessorContext.CapturedPunctuator holds captured punctuators, along with their scheduling information.
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.