Re: Convert a KStream to KTable

2016-10-10 Thread Michael Noll
Elias, yes, that is correct. I also want to explain why: One can always convert a KTable to a KStream (note: this is the opposite direction of what you want to do) because one only needs to iterate through the table to generate the stream. To convert a KStream into a KTable (what you want to do

Re: Convert a KStream to KTable

2016-10-07 Thread Matthias J. Sax
-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 That is correct. On 10/7/16 8:03 PM, Elias Levy wrote: > I am correct in assuming there is no way to convert a KStream into > a KTable, similar to KTable.toStream() but in the reverse > direction, other than using KSteam.reduceByKey and a Reducer or

Convert a KStream to KTable

2016-10-07 Thread Elias Levy
I am correct in assuming there is no way to convert a KStream into a KTable, similar to KTable.toStream() but in the reverse direction, other than using KSteam.reduceByKey and a Reducer or looping back through Kafka and using KStreamBuilder.table?