Hi Florian, I have updated this KIP and restarted the discussion to reduce scope to Processor API first, to then prepare another KIP to define behaviour on DSL functions.
Feel free to validate the current WIP and give feedback to check that KIP is supporting your use-case. Cheers, Jorge. El dom., 29 abr. 2018 a las 19:39, Ted Yu (<[email protected]>) escribió: > 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 < > [email protected]> 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 > > >
