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

Posted to commits@camel.apache.org by GitBox <gi...@apache.org> on 2022/05/17 12:46:40 UTC

[GitHub] [camel] ludovic-boutros commented on pull request #7518: CAMEL-18024: rework the last processed offset tracking

ludovic-boutros commented on PR #7518:
URL: https://github.com/apache/camel/pull/7518#issuecomment-1128825463

   Hi @orpiske , I just checked this PR. The async ConcurrentQueue is mandatory if you want to be able to commit offsets in an async process like an aggregation with completion timeout. this is because the commit function must be called by the consumer thread. If not you will get a ConcurrentModification exception.
   The use case is for instance to index documents in a bulk manner using aggregate and commit once indexed.
    


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org