KIP-844 — Transactional State Stores

Discarded StreamsTransactions

Proposes making Kafka Streams state store writes transactional so they atomically commit only after the corresponding changelog records are committed, eliminating the need to wipe and replay state stores after a crash with EOS enabled. With EOS, a Streams crash between commits leaves state stores in a partially-updated state that cannot be rolled back without a full changelog replay from the beginning.

Details