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, [email protected] wrote: > this is a kafka stream question!context.schedule(60 * 1000L);but punctuate > func run a time with in every avg 3 seconds > > > > [email protected] >
signature.asc
Description: OpenPGP digital signature
