Hello, I am really interested about the "KIP-244 <https://cwiki.apache.org/confluence/display/KAFKA/KIP-244> : Add record headers to Kafka Streams". I saw that the previous implementation hasn't change since december so I decided to start my own during this weekend. For now, only the `.filter((key, value, header) -> ...)` is working (Tests are in KStreamFilterTest.java). You can find the changes here: https://github.com/apache/kafka/compare/trunk...ImFlog:streams-headers
Can someone take a quick look at this and tell me if I'm heading toward the right direction ? Some things feels quite wrong as I am duplicating a lot because of the AbstractProcessor new `process` methods and the `forward` methods from ProcessorContextImpl.java. If the filter is well implemented, I will continue with the rest. Thank you by advance Florian Garcia
