ksqlDB delayed stream

ksqlDB
1

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.

2

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

3

Thank you @mjsax. I will try it out.

4

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