How to Get All Values within Window Interval in ksqlDB

To collect all records that fall within a window interval, you can use the COLLECT_LIST function.

For example, to collect all product names that are updated each day:

SELECT
  COLLECT_LIST(name)
FROM product_updates;
WINDOW TUMBLING (SIZE 1 DAY);

Was this article helpful?