Приветствую всех! Подскажите, пожалуйста, допустим есть: - топик ST(source topic) -

Question

Приветствую всех! Подскажите, пожалуйста, допустим есть: - топик ST(source topic) -

kstream S из топика ST
- ktable T который является аггрегацией стрима S
- kstream S2 который является join'ом S и T
Когда сообщение попадает в топик ST можно ли ожидать что оно сначала саггрегируется в ktable T прежде чем это аггрегированное значение попадет в join к S2?
Или же таких гарантий нет и возможно что сначала произойдет join с несвежими данными из T, а только потом таблица T будет обновлена для уже следущих джоинов?

Например здесь:
https://dzone.com/articles/join-semantics-in-kafka-streams
человек пишет:
>The KTable lookup is always done on the current state of the KTable; thus, out-of-order records can yield a non-deterministic result.
Но не совсем понятно пример выше попадает под это 'out-of-order'? И выходит 'current state' в примере выше никак не связан с тем что есть в исходном топике, потому что могло еще не саггрерироваться?

#kafka #russian #software

0

02.08.2019

1 ответов

10 просмотров

Vik Gamov · Accepted Answer

Vik Gamov

https://kafka-summit.org/sessions/zen-art-streaming-joins-2/ В этом видосе семантика джойнов рассказана ок

0

02.08.2019

52 похожих чатов

Приветствую всех! Подскажите, пожалуйста, допустим есть: - топик ST(source topic) -

1 ответов

Похожие вопросы