KIP-1035 — StateStore managed changelog offsets

Accepted Kafka 4.3 Streams

Allows Kafka Streams StateStore implementations to manage their own changelog topic offsets rather than delegating that responsibility to the engine's per-task .checkpoint file. The current centralized checkpoint file creates a tight coupling between the Streams engine and every store, preventing stores (e.g., RocksDB with remote storage) from atomically persisting their data and the corresponding changelog offset together.

Details