[
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
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);
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
> 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
> 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);
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
