RE: join 2 topic streams --> to another topic

2018-04-09 Thread adrien ruffie
n depending of timestamps why not, is it possible with windowing ? > > > Thank Matthias > > Adrien > > ________ > De : Matthias J. Sax > Envoyé : dimanche 8 avril 2018 23:04:24 > À : users@kafka.apache.org > Objet : Re: join 2 topic streams --> to anothe

Re: join 2 topic streams --> to another topic

2018-04-09 Thread Matthias J. Sax
imestamps why not, is it possible with windowing ? > > > Thank Matthias > > Adrien > > > De : Matthias J. Sax > Envoyé : dimanche 8 avril 2018 23:04:24 > À : users@kafka.apache.org > Objet : Re: join 2 topic streams --> to another topic >

RE: join 2 topic streams --> to another topic

2018-04-09 Thread adrien ruffie
che 8 avril 2018 23:04:24 À : users@kafka.apache.org Objet : Re: join 2 topic streams --> to another topic Check out this blog post that explain how the different joins work: https://www.confluent.io/blog/crossing-streams-joins-apache-kafka/ It's hard to give a general answer -- it depends o

Re: join 2 topic streams --> to another topic

2018-04-08 Thread Ted Yu
The blog is an interesting reading material. There was a minor typo: bq. an event arrives for either the left of right input stream 'of' above should be 'or'. Cheers On Sun, Apr 8, 2018 at 2:04 PM, Matthias J. Sax wrote: > Check out this blog post that explain how the different joins work: >

Re: join 2 topic streams --> to another topic

2018-04-08 Thread Matthias J. Sax
Check out this blog post that explain how the different joins work: https://www.confluent.io/blog/crossing-streams-joins-apache-kafka/ It's hard to give a general answer -- it depends on the context of your application. Are keys unique? Do you want to get exactly one result or should a single stoc

join 2 topic streams --> to another topic

2018-04-08 Thread adrien ruffie
Hello all, I have 2 topics streamed by KStream and one KStream I want to merge both object's informations (Stock & Dividend) and send to another topic with for example The key of 2 two topic is the same. I need to use, leftJoin, merge, KTable, ... what is the best solution ? What do you