Apache Kafka - Real-time Stream Processing (Master Class) - Creating Session Windows

The lecture explains session windows, which are periods of activity followed by inactivity, and how they differ from fixed-size time windows. Using a clickstream example, it demonstrates capturing user click events, streaming them to Kafka, and counting clicks per user session. The process of creating session windows in Kafka Streams is detailed, including handling late-arriving records and merging windows. The session window's behavior is illustrated with examples, highlighting its application in user behavior analysis.

What is a session window primarily based on?

• A fixed time interval

• A period of activity

• A user-defined time

• A random time interval

In the example, what is used as the message key for Kafka?

• Timestamp

• User ID

• User's session ID

• User's IP address

How is a new user session defined in the example?

• When a user logs out

• When a user logs in

• When a user clicks a link

• When a user is idle for 5 minutes

What method is used to group data in Kafka streams?

• Group by value

• Group by key

• Group by session

• Group by time

What happens when a new message arrives within the idle time boundary?

• The session window is closed

• The message is discarded

• The existing session window is extended

• A new session window is created

What operation is performed when extending a session window?

• Delete and recreate

• Merge and update

• Split and combine

• Pause and resume

What is the primary application area for session windows?

• Weather forecasting

• Stock market prediction

• User behavior analysis

• Financial analysis

What happens to a session window when a late message arrives?

• It creates a new window

• It is merged with the appropriate window

• It is ignored

• It is stored separately

How are session windows different from other window types?

• They are always longer

• They are always shorter

• They vary in length

• They are fixed in length

What is the outcome for user 101's sessions in the example?

• No visits recorded

• One visit with 5 clicks

• Three visits with 2 clicks each

• Two visits with 4 and 1 clicks