Ivan Vasyliev created CAMEL-8180:
------------------------------------
Summary: 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
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)
