I have a stream which has
My where clause is: state =
X and lastModifiedDate < (now - 30 minutes).
I have a 5 minutes tumbling window in my stream and i changed timestamp to now+32 minutes as millisecond epoch by a column.
Because my purpose is make ksqldb window function to evaluate this event after 30 minutes passed and if it satisfies my where clause create an event for that.
But ksqldb evaluates event instantly, even i change timestamp to now+N minutes.
Is there a way to make ksqldb to re-evaluate old my event after a specific time passed?