KIP-1271 — Allow to Store Headers in State Stores

Accepted Kafka 4.3 Streams

Extends Kafka Streams state stores to persist record headers alongside key and value bytes, introducing interfaces like TimestampedKeyValueStoreWithHeaders and VersionedKeyValueStoreWithHeaders. Currently, headers are stripped when records enter stateful operators, breaking header-dependent serdes (e.g., Schema Registry header-based schema-id format), tracing propagation, and any other header-carried semantics.

Details