Eno Thereska commented on KAFKA-4181:

Thanks for reporting this. Currently, this is indeed how Kafka Streams 
operates, since the system is "clocked" based on the arrival of events. There 
is discussion around clocking by system wallclock time, but this is not 
implemented yet. 

> Processors punctuate() methods call multiple times
> --------------------------------------------------
>                 Key: KAFKA-4181
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4181
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>    Affects Versions:,
>            Reporter: James Clinton
>            Assignee: Guozhang Wang
> I'm seeing odd behaviour whereby a Processor's punctuate(..) method is not 
> invoked based on the schedule, but builds up a backlog of pending punctuate() 
> calls that get flushed through when the Processors process() method is next 
> called.
> So for example:
> 1. Schedule the punctuate() methods to be called every second.  
> 2. A minute passes
> 3. Processor.process() receives a new message
> 4. Processor.punctuate(..) is invoked 60 times

This message was sent by Atlassian JIRA

Reply via email to