Yes, basically I'm ok with how join works including window and
retention periods, under normal circumstances. In real time of
occurrence of events, application joining streams will get something
like this:
T1 + 0 => topic_small (K1, V1) => join result (None)
T1 + 1 min => topic_large (K1, VT
Hi Murad,
On Wed, 26 Apr 2017 at 13:37 Murad Mamedov wrote:
> Is there any global time synchronization between streams in Kafka Streams
> API? So that, it would not consume more events from one stream while the
> other is still behind in time. Or probably better to rephrase it like, is
> there g
