enable.transactional.statestores — Kafka Kafka Streams Configuration

Whether to enable transactional state stores. When enabled, state stores will buffer writes in a transaction buffer (if supported by the state store implementation), before committing them when the corresponding Kafka changelog transaction has committed.Under EOS, state stores will no longer be wiped on-error and rebuilt from scratch

Description

Whether to enable transactional state stores. When enabled, state stores will buffer writes in a transaction buffer (if supported by the state store implementation), before committing them when the corresponding Kafka changelog transaction has committed.Under EOS, state stores will no longer be wiped on-error and rebuilt from scratch. In the event of an error (under either EOS or ALOS), only the writes since the last successful commit will be lost and replayed through the topology.

Default Values by Kafka Version