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

package org.apache.kafka.streams.processor.api

Provides a low-level programming model (Processor API, aka, PAPI) to express a (stateful) data flow computation over input topics. Use Topology as the entry point for your program.

Related Packages

Package	Description
org.apache.kafka.streams.processor	Provides a low-level programming model (Processor API, aka, PAPI) to express a (stateful) data flow computation over input topics.

Class	Description
ContextualFixedKeyProcessor<KIn,VIn,VOut>	An abstract implementation of FixedKeyProcessor that manages the FixedKeyProcessorContext instance and provides default no-op implementation of FixedKeyProcessor.close().
ContextualProcessor<KIn,VIn,KOut,VOut>	An abstract implementation of Processor that manages the ProcessorContext instance and provides default no-op implementation of Processor.close().
FixedKeyProcessor<KIn,VIn,VOut>	A processor of key-value pair records where keys are immutable.
FixedKeyProcessorContext<KForward,VForward>	Processor context interface for FixedKeyRecord.
FixedKeyProcessorSupplier<KIn,VIn,VOut>	A processor supplier that can create one or more FixedKeyProcessor instances.
FixedKeyRecord<K,V>	A data class representing an incoming record with fixed key for processing in a FixedKeyProcessor or a record to forward to downstream processors via FixedKeyProcessorContext.
InternalFixedKeyRecordFactory
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.
ProcessingContext	Processor context interface.
Processor<KIn,VIn,KOut,VOut>	A processor of key-value pair records.
ProcessorContext<KForward,VForward>	Processor context interface for Record.
ProcessorSupplier<KIn,VIn,KOut,VOut>	A processor supplier that can create one or more Processor instances.
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.
RecordMetadata