| 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 |
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 | 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(). |
| ConsumerRecordTimestampExtractor |
Retrieves built-in timestamps from Kafka messages (introduced in KIP-32: Add timestamps to Kafka message).
|
| DefaultPartitionGrouper |
Default implementation of the
PartitionGrouper interface that groups partitions by the partition id. |
| 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 | |
| WallclockTimestampExtractor |
Retrieves current wall clock timestamps as
System.currentTimeMillis(). |