Jorge, Thanks for the KIP, I know this is a feature others in the community have been interested in getting into Kafka Streams.
I took a quick pass over it, and I have one initial question. We recently reduced overloads with KIP-182, and in this KIP we are increasing them again. I can see from the KIP why they are necessary, but I'm wondering if there is something else we can do to cut down on the overloads introduced. I don't have any sound suggestions ATM, so I'll have to think about it some more, but I wanted to put the thought out there. Thanks, Bill On Thu, Dec 21, 2017 at 9:06 AM, Jorge Esteban Quilcate Otoya < quilcate.jo...@gmail.com> wrote: > 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. >