я использую
KStream.join(KStream other, ValueJoiner joiner, JoinWindows)
возьмем этот пример:
Поток 1 ------------------- Поток 2
ключ | Значение ----------------- ключ | Значение
1 | A ------------------------ 1 | А
2 | B ----------------------- 2 | B
3 | C ----------------------- 3 | C
1 | D ------------------------ 4 | D
1 | E ------------------------ 2 | E
каков результат этого потока, заставляющего KStream 1 присоединяться к KStream 2
скажем, все в одном окне





Все записи попадают в скользящее окно, которое вы получите
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/
Зависит от размера вашего окна ... Ознакомьтесь с этим сообщением в блоге, в котором подробно объясняется объединение в потоках Kafka: confluent.io/blog/crossing-streams-joins-apache-kafka