Stateful Stream Processing
Stateful Stream Processing is…FIXME
|
Note
|
A StateStore can be local or global (although it is a property of a ProcessorTopology).
|
Kafka Streams developers use Stores utility for creating state stores.
|
Note
|
A StateStore can be backed by a changelog topic in the Kafka cluster for fault-tolerance, i.e. with logging enabled (although it is an implementation detail, and not part of the StateStore contract). Kafka Streams developers use Materialized or StoreBuilder APIs to control logging.
|
|
Note
|
A StateStore can be cached for performance, i.e. with caching enabled (although it is an implementation detail, and not part of the StateStore contract). Kafka Streams developers use Materialized or StoreBuilder APIs to control logging.
|