[
https://issues.apache.org/jira/browse/KAFKA-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496575#comment-15496575
]
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: 0.10.0.0, 0.10.0.1
> 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
(v6.3.4#6332)
