[CAMEL-8180] Incorrect handling of ConsumerTimeoutException

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.15.0
• Component/s: camel-kafka
• Patch Info: Patch Available
• Estimated Complexity: Unknown
• Assignee: Willem Jiang
• Reporter: Ivan Vasyliev
• Created: 24/Dec/14 11:08
• Updated: 25/Dec/14 08:37
• Resolved: 25/Dec/14 08:37

Description

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.