Skip to content

Windowing

Windowing allows you to bucket stateful operations by time, without which your aggregations would endlessly accumulate. A window gives you a snapshot of an aggregate within a given timeframe, and can be set as hopping, tumbling, session, or sliding.

Reference: https://developer.confluent.io/courses/kafka-streams/windowing/

Components

Windowed

The 'windowed' component of the KSTD Excalidraw library

windowed stream processing groups records by their keys within a defined time window, allowing operations like joins or aggregations to be performed on data that occurs within the same time range.

Kafka Streams supports the following window types:
[Tumbling; Sliding; Hopping; Session]