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?
>
>
>
