KIP-1253 — Add TopologyValidator Utility for Kafka Streams Topology Compatibility

Discussion StreamsTesting

Proposes a TopologyValidator utility for Kafka Streams that detects breaking topology changes between deployments — such as internal topic renames, state store name shifts from added source nodes, or changed source/sink topics — before they cause data loss or silent state reset. Kafka Streams auto-generates incremental identifiers for unnamed nodes and stores, so inserting a new source node early in the topology silently shifts all downstream node names, reassigning changelog and repartition topics.

Details