Package org.apache.kafka.streams.processor

package 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. Use Topology as the entry point for your program.

Related Packages

Package	Description
org.apache.kafka.streams	Provides the Kafka Streams library for building streaming data applications.
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.
org.apache.kafka.streams.errors	Provides common exception classes for Streams applications.
org.apache.kafka.streams.kstream	Provides a high-level programming model (DSL) to express a (stateful) data flow computation over input streams and tables.
org.apache.kafka.streams.query	Provides a query API (aka Interactive Queries) over state stores, for extracting data from a stateful Kafka Streams application.
org.apache.kafka.streams.state	Provides interfaces for managing the intermediate state of a stateful streams application.
org.apache.kafka.streams.test	Provides classes for testing Kafka Streams applications with mocked inputs.

Class	Description
AbstractProcessor<K,V>	Deprecated. Since 3.0.
BatchingStateRestoreCallback	Interface for batching restoration of a StateStore It is expected that implementations of this class will not call the StateRestoreCallback.restore(byte[], byte[]) method.
Cancellable	Cancellable interface returned in ProcessorContext.schedule(Duration, PunctuationType, Punctuator).
CommitCallback	Stores can register this callback to be notified upon successful commit.
ConnectedStoreProvider	Provides a set of StoreBuilders that will be automatically added to the topology and connected to the associated processor.
FailOnInvalidTimestamp	Retrieves embedded metadata timestamps from Kafka messages.
LogAndSkipOnInvalidTimestamp	Retrieves embedded metadata timestamps from Kafka messages.
MockProcessorContext	MockProcessorContext is a mock of ProcessorContext for users to test their Processor, Transformer, and ValueTransformer implementations.
MockProcessorContext.CapturedForward
MockProcessorContext.CapturedPunctuator	MockProcessorContext.CapturedPunctuator holds captured punctuators, along with their scheduling information.
Processor<K,V>	Deprecated. Since 3.0.
ProcessorContext	Processor context interface.
ProcessorSupplier<K,V>	Deprecated. Since 3.0.
PunctuationType	Controls what notion of time is used for punctuation scheduled via ProcessorContext.schedule(Duration, PunctuationType, Punctuator) schedule}: STREAM_TIME - uses "stream time", which is advanced by the processing of messages in accordance with the timestamp as extracted by the TimestampExtractor in use.
Punctuator	A functional interface used as an argument to ProcessorContext.schedule(Duration, PunctuationType, Punctuator).
RecordContext	The context associated with the current record being processed by a Processor
StateRestoreCallback	Restoration logic for log-backed state stores upon restart, it takes one record at a time from the logs to apply to the restoring state.
StateRestoreListener	Class for listening to various states of the restoration process of a StateStore.
StateStore	A storage engine for managing state maintained by a stream processor.
StateStoreContext	State store context interface.
StreamPartitioner<K,V>	Determine how records are distributed among the partitions in a Kafka topic.
TaskId	The task ID representation composed as subtopology (aka topicGroupId) plus the assigned partition ID.
TaskMetadata	Deprecated. since 3.0, use TaskMetadata instead.
ThreadMetadata	Deprecated. since 3.0 use ThreadMetadata instead
TimestampExtractor	An interface that allows the Kafka Streams framework to extract a timestamp from an instance of ConsumerRecord.
To	This class is used to provide the optional parameters when sending output records to downstream processor using ProcessorContext.forward(Object, Object, To).
TopicNameExtractor<K,V>	An interface that allows to dynamically determine the name of the Kafka topic to send at the sink node of the topology.
UsePartitionTimeOnInvalidTimestamp	Retrieves embedded metadata timestamps from Kafka messages.
WallclockTimestampExtractor	Retrieves current wall clock timestamps as System.currentTimeMillis().