Advanced
Components
Punctuator
Punctuator is a callback interface in Kafka Streams that triggers periodic actions in processors, allowing time-based processing on 'wall clock time' or 'stream time'.
Use in combination with Processor API (process/processValues).
Use in combination with Processor API (process/processValues).
Partitioner
Partitioner is responsible for determining which partition a record will be sent to based on its key, allowing control over how data is distributed across partitions in Kafka.
Use in combination with the repartition DSL operator.
Use in combination with the repartition DSL operator.
Stateful
These additional indicators are provided for arbitrary use. You can use them as you see fit or helpful. You can find an example in the bonus step of the KSTD tutorial.
Stateful Indicator. Refers to operations in Kafka Streams that rely on maintaining state, such as joins, aggregations, or windowed computations.
Stateful Indicator (2). Alternative visual library component.
Repartitioned
These additional indicators are provided for arbitrary use. You can use them as you see fit or helpful. You can find an example in the bonus step of the KSTD tutorial.
Repartitioned Indicator. Refers to redistributing data across new partitions, often necessary when a key-changing operation like `selectKey()` is applied in Kafka Streams.
Repartitioned Indicator (2). Alternative visual library component.