hi Alieh Thanks for the KIP. This proposal seems to open the door for many interesting use cases. I have a few questions?
chia_0: could you clarify the serialization format of headers_bytes? chia_1: how does the state store distinguish between legacy values and new values with headers? Since the new format starts with a 2-bytes length, is there a risk of ambiguity with existing data? chia_2: does the implementation guarantee that the order of headers is preserved Best, Chia-Ping > Alieh Saeedi via dev <[email protected]> 於 2026年1月10日 清晨6:14 寫道: > > Hi all, > > I’d like to start a discussion on KIP-1271, which proposes allowing Kafka > Streams state stores to preserve record headers. > This would let header-based metadata like schema IDs, tracing info, and > feature flags be stored and restored alongside values. > The KIP introduces header-aware store types and a small config to cap the > size of headers written into state. > Details are in the KIP: > https://cwiki.apache.org/confluence/display/KAFKA/KIP-1271%3A+Allow+to+Store+Record+Headers+in+State+Stores > . > I’d appreciate your feedback and questions on the proposal. > > Thanks, > Alieh
