Re: KStream-KTable join with the KTable given a "head start"

2016-04-01 Thread Guozhang Wang
ding arrives on the >>>>> KStream. If >>>>> the KStream record arrives first, however, we'll get a null join even >>>>> if >>>>> the KTable gets the corresponding record only milliseconds later. >>>>> >>>>

Re: KStream-KTable join with the KTable given a "head start"

2016-03-30 Thread Jeff Klukas
pdated before the corresponding records arrive on the > KStream. Could I achieve this using one of the existing Windowing > strategies? > > > -- Forwarded message -- > From: Guozhang Wang > To: "users@kafka.apache.org" > Cc: > Date: Wed, 30 Mar

Re: KStream-KTable join with the KTable given a "head start"

2016-03-30 Thread Guozhang Wang
Hi Jeff, This is a common case of stream-table join, in that the joining results depending on the arrival ordering from these two sources. In Kafka Streams you can try to "synchronize" multiple input streams through the "TimestampExtractor" interface, which is used to assign a timestamp to each r