Hi all, I have created a KIP to add Record Headers support to Kafka Streams API: https://cwiki.apache.org/confluence/display/KAFKA/KIP-244%3A+Add+Record+Header+support+to+Kafka+Streams
The main goal is to be able to use headers to filter, map and process records as streams. Stateful processing (joins, windows) are not considered. Proposed changes/Draft: https://github.com/apache/kafka/compare/trunk...jeqo:streams-headers Feedback and suggestions are more than welcome. Cheers, Jorge.
