Kafka KStream-KStream窗口化加入说明答案

【问题标题】：Kafka KStream-KStream windowed Join explanationKafka KStream-KStream窗口化加入说明
【发布时间】：2018-09-18 02:45:54
【问题描述】：

我正在使用

KStream.join(KStream other, ValueJoiner 加入者，加入Windows）

让我们举个例子：

流 1-------流 2

键 |值-----------------键 |价值

1 |一个------------1 |一个

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

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

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

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

这个流使 KStream 1 加入 KStream 2 的结果是什么

【问题讨论】：

取决于您的窗口大小...查看这篇博文，详细解释 Kafka Streams 中的连接：confluent.io/blog/crossing-streams-joins-apache-kafka
让我们说所有都在同一个窗口中

【解决方案1】：

所有记录都落入您将获得的滑动窗口

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

【讨论】：