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
