CODEWITHSUNDEEP
joinapache-kafkaapache-kafka-streams
Anthony
Anthony

Reputation: 661

Kafka KStream-KStream windowed Join explanation

I am using

KStream.join(KStream other, ValueJoiner joiner, JoinWindows)

let's take this example:

Stream 1-------------------Stream 2

key | Value-----------------key | Value

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

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

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

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

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

what is the result of this stream making a KStream 1 join KStream 2

Upvotes: 0

Views: 1224

Answers (1)

Matthias J. Sax
Matthias J. Sax

Reputation: 62350

It all records fall into the sliding window you would get

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

The blog post mentions explains it: https://www.confluent.io/blog/crossing-streams-joins-apache-kafka/

Upvotes: 2

Related Questions