A partition grouper that generates partition groups given the list of topic-partitions.
A processor of key-value pair records.
Processor context interface.
A processor supplier that can create one or more
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.
A storage engine for managing state maintained by a stream processor.
A state store supplier which can create one or more
Determine how records are distributed among the partitions in a Kafka topic.
An interface that allows the Kafka Streams framework to extract a timestamp from an instance of
Retrieves built-in timestamps from Kafka messages (introduced in KIP-32: Add timestamps to Kafka message).
Default implementation of the
The task ID representation composed as topic group ID plus the assigned partition ID.
A component that is used to build a
Retrieves current wall clock timestamps as