James Clinton created KAFKA-4181:

             Summary: 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 

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