Thanks for the KIP. I am not sure if I understand the motivation. In particular the KIP says:
> The main problem, apart from needing more code, is that if the same event is > received twice at the same time and the commit time is not 0, the difference > is deleted and nothing is emitted. Can you elaborate? Maybe you can provide a concrete example? I don't understand the relationship between "the same event is received twice" and a "non-zero commit time". -Matthias On 10/6/20 6:25 AM, Javier Freire Riobo wrote: > Hi all, > > I'd like to propose these changes to the Kafka Streams API. > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-675%3A+Convert+KTable+to+a+KStream+using+the+previous+value > > This is a proposal to convert a KTable to a KStream knowing the previous > value of the registry. > > I also opened a proof-of-concept PR: > > PR#9321: https://github.com/apache/kafka/pull/9381 > > What do you think? > > Cheers, > Javier Freire >
