在Kafka流连接中,第二个连接字段是否会排队等待第一个字段在窗口中连接?

问题描述 投票:0回答:1

假设我们有两个Kafka流,其中流1的A必须与流2的A合并。流1的B必须与流2的B合并。A1-> A2B1-> B2

[其中'->'表示连接,带字母的相应数字表示流的数量。

现在,让我们看下面的示例:

流1 ---流2 ---加入一种乙B(B,B)现在,我的问题是:((B,B)加入会发生还是先等待流1的A到达以便A1-> A2可以首先发生?

apache-kafka apache-kafka-streams confluent
1个回答
0
投票

根据融合文档:

Kstreams中有三个联接:1.内部加入2.左加入3.右键加入

Sr.no。 -> LeftStream1-> RightStream->内部联接->左联接->外部联接

  1. -> null-> A-> null-> null-> null

  2. -> B-> null-> [B,A]-> [B,A]-> [B,A]

  3. -> null-> B-> [B,A],[B,B] | -> [B,A],[B,B]-> [B,A],[B,B]

[B,A]之间的连接将首先发生,因为右流已经具有一个现有的值,并且当一个值进入左流时(如第2条中所示),它将执行所有三个连接。

© www.soinside.com 2019 - 2024. All rights reserved.