假设我们有两个Kafka流,其中流1的A必须与流2的A合并。流1的B必须与流2的B合并。A1-> A2B1-> B2
[其中'->'表示连接,带字母的相应数字表示流的数量。
现在,让我们看下面的示例:
流1 ---流2 ---加入一种乙B(B,B)现在,我的问题是:((B,B)加入会发生还是先等待流1的A到达以便A1-> A2可以首先发生?
根据融合文档:
Kstreams中有三个联接:1.内部加入2.左加入3.右键加入
Sr.no。 -> LeftStream1-> RightStream->内部联接->左联接->外部联接
-> null-> A-> null-> null-> null
-> B-> null-> [B,A]-> [B,A]-> [B,A]
-> null-> B-> [B,A],[B,B] | -> [B,A],[B,B]-> [B,A],[B,B]
[B,A]之间的连接将首先发生,因为右流已经具有一个现有的值,并且当一个值进入左流时(如第2条中所示),它将执行所有三个连接。