kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Bin Zhu <minc.zhu...@gmail.com>
Subject Re: How to create scheduled tasks in Kafka Stream?
Date Mon, 09 Jul 2018 19:28:29 GMT
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 <wangguoz@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.zhubin@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
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message