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
