[
https://issues.apache.org/jira/browse/CAMEL-8180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Vasyliev updated CAMEL-8180:
---------------------------------
Attachment: Handle_consumer_timeout_properly.patch
> Incorrect handling of ConsumerTimeoutException
> ----------------------------------------------
>
> Key: CAMEL-8180
> URL: https://issues.apache.org/jira/browse/CAMEL-8180
> Project: Camel
> Issue Type: Improvement
> Components: camel-kafka
> Reporter: Ivan Vasyliev
> Fix For: 2.15.0
>
> Attachments: Handle_consumer_timeout_properly.patch
>
>
> When there is 1 consumer connector and multiple consumer threads, the idea to
> handle consumer offset is to sync all consumer threads via cyclic barrier. In
> order to make sure threads will step on the barrier - "consumer.timeout.ms"
> property needs to be set, otherwise all threads may wait infinite time on
> "hasNext()" iterator call, since number of partitions can be less than number
> of threads.
> Attaching patch which fixes handling of ConsumerTimeoutException.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
