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:
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)
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.