Otavio Rodolfo Piske created CAMEL-18024:
--------------------------------------------
Summary: camel-kafka: rework last processed offset tracking
Key: CAMEL-18024
URL: https://issues.apache.org/jira/browse/CAMEL-18024
Project: Camel
Issue Type: Task
Reporter: Otavio Rodolfo Piske
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)
