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