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

• Interface Summary 

  Interface	Description
  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.
  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.
  RecordMetadata

• Class Summary 

  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().
  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
  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.

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