Join operations (KStream-KStream, KStream-KTable) in Kafka - Cheat Sheet & Quick Revision

Recall & Review

beginner

What is a KStream-KStream join in Kafka Streams?

A KStream-KStream join combines two continuous streams of data based on matching keys within a specified time window, producing a new stream with joined records.

beginner

How does a KStream-KTable join differ from a KStream-KStream join?

A KStream-KTable join combines a stream with a table (a changelog of updates), joining each stream record with the latest table value for the matching key, without a time window.

intermediate

What is the role of the time window in a KStream-KStream join?

The time window defines how far apart in time two records with the same key can be to be joined. Only records arriving within this window are joined.

beginner

Why is a KTable considered a 'table' in Kafka Streams?

Because a KTable represents a changelog stream that models the latest state for each key, like a database table with current values.

intermediate

What happens if a KStream record key does not exist in the KTable during a KStream-KTable join?

The join result will be null or absent for the KTable side, so the output depends on the join type (e.g., left join keeps the stream record with null table value).

In a KStream-KStream join, what determines which records are joined?

A Matching keys within a time window

B Matching keys without time constraints

C All records regardless of keys

D Only records from the first stream

KStream-KStream joins require matching keys and that records arrive within a specified time window to be joined.

What type of join allows a KStream to join with the latest state of a KTable?

A KStream-KStream join

B GlobalKTable join

C KTable-KTable join

D KStream-KTable join

KStream-KTable join combines a stream with the latest state from a table (KTable).

Which join type in Kafka Streams uses a time window?

A KStream-KStream join

B KStream-KTable join

C KTable-KTable join

D None of the above

Only KStream-KStream joins require a time window to match records.

If a KStream record key is missing in the KTable during a left join, what is the output?

A The record is dropped

B The record is joined with null for the KTable value

C An error occurs

D The record is duplicated

In a left join, the stream record is kept with null for the missing table value.

What does a KTable represent in Kafka Streams?

A A stream of events

B A batch of records

C A changelog stream representing the latest state per key

D A static file

A KTable models the latest state for each key as a changelog stream.

Explain how a KStream-KStream join works and why a time window is important.

Think about how two live streams combine their records based on time and keys.

Describe the difference between a KStream-KTable join and a KStream-KStream join.

Consider how a stream joins with a changing table versus another stream.