Re: Streams - merging multiple topics

2016-11-22 Thread Brian Krahmer
Thanks Damian! Based on your response, I finally got it working. I did end up using left joins and added a final step that goes from table -> stream and then filters out nulls. thanks, brian On 21.11.2016 22:03, Damian Guy wrote: Hi Brian, It sounds like you might want do something like:

Re: Streams - merging multiple topics

2016-11-21 Thread Damian Guy
Hi Brian, It sounds like you might want do something like: KTable inputOne = builder.table("input-one"); KTable inputTwo = builder.table("input-two"); KTable inputThree = builder.table("input-three"); ValueJoiner joiner1 = //... ValueJoiner joiner2 = //... inputOne.join(inputTwo, joiner1)

Streams - merging multiple topics

2016-11-21 Thread Brian Krahmer
Hey guys. I've been banging my head for about 3 days now trying to get a streams application working with no luck. I've read through all of the docs and examples I can find, and just am not getting it. I'm using 0.10.1 and have worked quite a bit with the high-level consumer and publisher.