Hello Guozhang, Thanks for the information. I read the document, but that doesn't seem to solve my problem. In my use case, the timers need to be triggered by events and the processing of a event is postponed for a certain amount of time (e.g. 5 minutes). So it's going to be one timer per event.
I looked at both "PunctuationType.STREAM_TIME" and "PunctuationType.WALL_CLOCK_TIME": I don't see the timers are triggered by an event in either settings: in the first setting, if there's no more new events, the timer is stopped; in the second setting, there's only one "global" timer. Thanks, Bin On Mon, Jul 9, 2018 at 1:03 PM, Guozhang Wang <wangg...@gmail.com> wrote: > Hello Bin, > > You can take a look at the scheduled punctuate function, which should suit > your needs: > > https://kafka.apache.org/documentation/streams/ > developer-guide/processor-api.html#defining-a-stream-processor > > > Guozhang > > On Mon, Jul 9, 2018 at 9:09 AM, Bin Zhu <minc.zhu...@gmail.com> wrote: > > > Hello, > > > > Is there any way to run scheduled tasks in Kafka Stream? > > The use case is like: once the event is received, after 5 minutes (no new > > events are coming at that time), run the job with that event. Is it > doable > > via processor API or DSL? > > > > Thanks, > > Bin > > > > > > -- > -- Guozhang >
