Package org.apache.kafka.streams.processor

Interface Summary

Interface	Description
PartitionGrouper	A partition grouper that generates partition groups given the list of topic-partitions.
Processor<K,V>	A processor of key-value pair records.
ProcessorContext	Processor context interface.
ProcessorSupplier<K,V>	A processor supplier that can create one or more Processor instances.
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.
StateStore	A storage engine for managing state maintained by a stream processor.
StateStoreSupplier<T extends StateStore>	A state store supplier which can create one or more StateStore instances.
StreamPartitioner<K,V>	Determine how records are distributed among the partitions in a Kafka topic.
TimestampExtractor	An interface that allows the Kafka Streams framework to extract a timestamp from an instance of ConsumerRecord.

Class Summary

Class	Description
AbstractProcessor<K,V>	An abstract implementation of Processor that manages the ProcessorContext instance and provides default no-op implementations of AbstractProcessor.punctuate(long) and AbstractProcessor.close().
DefaultPartitionGrouper	Default implementation of the PartitionGrouper interface that groups partitions by the partition id.
FailOnInvalidTimestamp	Retrieves embedded metadata timestamps from Kafka messages.
LogAndSkipOnInvalidTimestamp	Retrieves embedded metadata timestamps from Kafka messages.
TaskId	The task ID representation composed as topic group ID plus the assigned partition ID.
TopologyBuilder	A component that is used to build a ProcessorTopology.
TopologyBuilder.TopicsInfo
UsePreviousTimeOnInvalidTimestamp	Retrieves embedded metadata timestamps from Kafka messages.
WallclockTimestampExtractor	Retrieves current wall clock timestamps as System.currentTimeMillis().

Enum Summary

Enum	Description
TopologyBuilder.AutoOffsetReset	Enum used to define auto offset reset policy when creating KStream or KTable