[
https://issues.apache.org/jira/browse/CAMEL-18024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Otavio Rodolfo Piske updated CAMEL-18024:
-----------------------------------------
Fix Version/s: 3.17.0
> camel-kafka: rework last processed offset tracking
> --------------------------------------------------
>
> Key: CAMEL-18024
> URL: https://issues.apache.org/jira/browse/CAMEL-18024
> Project: Camel
> Issue Type: Task
> Components: camel-kafka
> Reporter: Otavio Rodolfo Piske
> Priority: Major
> Fix For: 3.17.0
>
>
> The record fetcher keeps track of the last processed offset via HashMap that
> associates the partition+key pair to an offset. This is primarily used for
> rollbacks and commits when doing manual commit management.
> We should probably move this within the commit management code to further
> simplify the code.
>
> Also, as [pointed
> here|https://github.com/apache/camel/pull/7503#issuecomment-1111119006], the
> data structure in use is not thread-safe.
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
