Hey Matthias, thanks for taking a look! It would be great to see this pushed in 2.2. Depending on the tight timeline, I hope to at least get the KIP approved so that we don't see back and forth again as the KTable API has been constantly changing. I couldn't guarantee the implementation timeline until we agree on the updated high level APIs first. Does that make sense?
Best, Boyang ________________________________ From: Matthias J. Sax <matth...@confluent.io> Sent: Sunday, January 13, 2019 10:53 AM To: dev@kafka.apache.org Subject: Re: [DISCUSS] KIP-300: Add Windowed KTable API in StreamsBuilder Do you want to get this into 2.2 release? KIP deadline is 1/24, so quite soon. Overall, the KIP is very useful. I can review again in more details if you aim for 2.2 -- did you address all previous comment about the KIP already? -Matthias On 1/8/19 2:50 PM, Boyang Chen wrote: > Hey folks, > > I would like to start a discussion thread on adding new time/session windowed > KTable APIs for KStream: > https://cwiki.apache.org/confluence/display/KAFKA/KIP-300%3A+Add+Windowed+KTable+API+in+StreamsBuilder > > We have been working on this thread around 7 months ago, and it is > successfully applied in our internal stream applications that enable > data sharing across multiple jobs. As a matter of fact, materialization of > windowed store is definitely a concrete use case that could unblock stream > users to > build more complex modules. > > Let me know if the API changes makes sense. > > Best, > Boyang > KIP-300: Add Windowed KTable API in StreamsBuilder - Apache Kafka - Apache > Software > Foundation<https://cwiki.apache.org/confluence/display/KAFKA/KIP-300%3A+Add+Windowed+KTable+API+in+StreamsBuilder> > We have an existing table() API in the StreamsBuilder which could materialize > a Kafka topic into a local state store called KTable. This interface is very > useful when we want to back up a Kafka topic to local store. Sometimes we > have certain requirement to materialize a windowed topic (or changlog ... > cwiki.apache.org > > >
