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?