[Solved] Find the bug in this Kafka Streams session window code:stream.groupByKey() .windowedBy(SessionWindows.with(Duration.ofSeconds(30))) .count() | Kafka

Kafka - Streams

Find the bug in this Kafka Streams session window code:

stream.groupByKey()
  .windowedBy(SessionWindows.with(Duration.ofSeconds(30)))
  .count()

AMissing .toStream() after count() causes error

BSessionWindows.with() is deprecated; use withInactivityGap() instead

CNo bug; code is correct

DSessionWindows.with() requires an inactivity gap, not window size

Step-by-Step Solution

Solution:

Step 1: Understand SessionWindows.with() parameter
SessionWindows.with(Duration.ofSeconds(30)) correctly sets the inactivity gap to 30 seconds for the session window.
Step 2: Check code correctness
The code groups by key, applies session windowing, and counts events, producing a valid windowed aggregation.
Final Answer:
No error; code is correct -> Option C
Quick Check:
SessionWindows.with() = valid inactivity gap configuration [OK]

Quick Trick: SessionWindows.with() sets inactivity gap, not fixed window size [OK]

Common Mistakes:

MISTAKES

Master "Streams" in Kafka

9 interactive learning modes - each teaches the same concept differently

More Kafka Quizzes

Find the bug in this Kafka Streams session window code: