[
https://issues.apache.org/jira/browse/KAFKA-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
James Clinton updated KAFKA-4181:
---------------------------------
Description:
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
was:
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
Update
My properties has the following set which seemed to cause the issue. So
without the following line, the punctuate() methods is called only once given
the steps above.
props.put(StreamsConfig.TIMESTAMP_EXTRACTOR_CLASS_CONFIG,
WallclockTimestampExtractor.class);
> 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)
