kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax" <matth...@confluent.io>
Subject Re: why punctuate fun run more times than schedule
Date Fri, 22 Sep 2017 06:21:17 GMT
punctuations are event-time based, not wall-clock time base.

We add wall-clock based punctuations to next release thought.

Cf.
https://docs.confluent.io/current/streams/developer-guide.html#defining-a-stream-processor


-Matthias

On 9/21/17 8:01 PM, 805930379@qq.com wrote:
> this is a kafka stream  question!context.schedule(60 * 1000L);but punctuate func run
a time with in every avg 3 seconds
> 
> 
> 
> 805930379@qq.com
> 


Mime
View raw message