Hello Elias, Thanks for reporting! I will follow-up with you on the created JIRA ticket.
Guozhang On Mon, Sep 12, 2016 at 4:01 PM, Elias Levy <fearsome.lucid...@gmail.com> wrote: > https://issues.apache.org/jira/browse/KAFKA-4153 > https://github.com/apache/kafka/pull/1846 > > On Mon, Sep 12, 2016 at 7:00 AM, Elias Levy <fearsome.lucid...@gmail.com> > wrote: > > > Any ideas? > > > > > > On Sunday, September 11, 2016, Elias Levy <fearsome.lucid...@gmail.com> > > wrote: > > > >> Using Kafka 0.10.0.1, I am joining records in two streams separated by > >> some time, but only when records from one stream are newer than records > >> from the other. > >> > >> I.e. I am doing: > >> > >> stream1.join(stream2, valueJoiner, JoinWindows.of("X").after(10000)) > >> > >> I would expect that the following would be equivalent: > >> > >> stream2.join(stream1, valueJoiner, JoinWindows.of("X").before(10000)) > >> > >> Alas, I find that this is not the case. To generate the same output as > >> the first example I must do: > >> > >> stream2.join(stream1, valueJoiner, JoinWindows.of("X").after(10000)) > >> > >> What am I missing? > >> > >> > >> > -- -- Guozhang
