Hi All, Keeping this thread alive!!
The aim is to add two methods Kstream.toTable() & Kstream.toTable(Materialized<K,V>), so users can choose to convert their event stream into a changelog stream at any stage. wiki link : https://cwiki.apache.org/confluence/display/KAFKA/KIP-523:+Add+KStream%23toTable+to+the+Streams+DSL jira ticket : https://issues.apache.org/jira/browse/KAFKA-7658 Best, Aishwarya On Fri, Sep 13, 2019 at 10:49 AM aishwarya kumar <ash26...@gmail.com> wrote: > Hello, > > Starting this thread to discuss KIP-532: > wiki link : > https://cwiki.apache.org/confluence/display/KAFKA/KIP-523:+Add+KStream%23toTable+to+the+Streams+DSL > jira ticket : https://issues.apache.org/jira/browse/KAFKA-7658 > > There has been some discussion around the use-case of this KIP in the Jira > ticket. > > Regards, > Aishwarya >