You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@camel.apache.org by "Ivan Vasyliev (JIRA)" <ji...@apache.org> on 2014/12/24 12:09:13 UTC

[jira] [Created] (CAMEL-8180) Incorrect handling of ConsumerTimeoutException

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)