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?

Reply via email to