The KIP is still under discussion. Have you seen this thread ?
http://search-hadoop.com/m/Kafka/uyzND1cGBCC19brXW?subj=Re+KIP+244+Add+Record+Header+support+to+Kafka+Streams FYI On Sun, Apr 29, 2018 at 10:29 AM, Florian Garcia < garcia.florian.pe...@gmail.com> wrote: > 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 >
