Kafka KStream-KStream оконное объяснение соединения

Я использую

KStream.join (другой KStream, соединитель ValueJoiner, JoinWindows)

возьмем этот пример:

Поток 1 ------------------- Поток 2

ключ | Значение ----------------- ключ | Ценить

1 | A------------------------1 | A

2 | B -----------------------2 | B

3 | C -----------------------3 | C

1 | D------------------------4 | D

1 | E------------------------2 | E

каков результат этого потока, заставляющего KStream 1 присоединяться к KStream 2


apache-kafka join apache-kafka-streams
person Anthony    schedule 08.04.2018    source источник
comment
Зависит от размера вашего окна ... Ознакомьтесь с этим сообщением в блоге, в котором подробно объясняется объединение в потоках Kafka: confluent.io/blog/crossing-streams-joins-apache-kafka   -  person Matthias J. Sax    schedule 08.04.2018
comment
скажем, все в одном окне   -  person Anthony    schedule 08.04.2018

Ответы (1)


arrow_upward
2
arrow_downward

Все записи попадают в скользящее окно, которое вы получите

1 (A-A), 2 (B-B), 3 (C-C), 1 (D-A), 1 (E-A), 2 (B-E)

В сообщении в блоге это объясняется: https://www.confluent.io/blog/crossing-streams-joins-apache-kafka/

person Matthias J. Sax    schedule 08.04.2018