KIP-698 — Add Explicit User Initialization of Broker-side State to Kafka Streams

Accepted Streams

KIP-698 adds a `KafkaStreams.cleanUp()` equivalent `addBrokerSideInitialization()` method and an `internal.topics.creation.mode` config (ENABLED/DISABLED) that allows users to pre-create internal topics (repartition, changelog) explicitly before the first application run. Previously, internal topics were silently recreated as empty topics when deleted between rebalances, causing undetected data loss without any user notification.

Details