Uploaded image for project: 'Camel'
  1. Camel
  2. CAMEL-8180

Incorrect handling of ConsumerTimeoutException

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 2.15.0
    • camel-kafka
    • None
    • Patch Available
    • Unknown

    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.

      Attachments

        Activity
          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            njiang Willem Jiang
            vasilievip Ivan Vasyliev
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment