ksqlDB delayed stream

Is it possible to implement delayed streams in ksqlDB? For example, I have a topic called “Page_Reads” and an event will be published on this topic whenever a page is read. I would like to create a stream with a window of 10 minutes but I want the result to be consumed only after the window is completed.

Let’s say we are talking about the window t1-t2 and within this window, a page was read 5 times. I would like to create a persistent query that will publish a message with Page Id and Read count once the window is over (Just one message per window after the window is over). Appreciate your response.

You can use EMIT FINAL instead of EMIT CHANGES to do this.

Thank you @mjsax. I will try it out.

This topic was automatically closed after 30 days. New replies are no longer allowed.