Hello Bin, Could you share a bit more on your scenario, i.e. why you'd want this delayed processing functionality so that I can try to think if there's better way to accommodate it?
Guozhang On Mon, Jul 9, 2018 at 12:28 PM, Bin Zhu <minc.zhu...@gmail.com> wrote: > 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 > > > -- -- Guozhang
