Re: Kafka Streams table persistence

2016-06-16 Thread Eno Thereska
Hi Jan, It's a good question. Your observations are correct. A KTable is sometimes materialised to a changelog topic lazily, depending on whether the result in the KTable is needed for subsequent operations or not. We are working to improving the documentation of the materialisation rules and

Kafka Streams table persistence

2016-06-16 Thread Jan Ehrhardt
Hi, I am curious about the relationship of KTables and state store in Kafka Streams. When I create a table with the `table` method, it uses the original topic as a changelog, thus persisting a table changelog does not make much sense. When I create invoke `countByKey` on a KStream, the result is a