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 > > >
signature.asc
Description: OpenPGP digital signature
