orpiske commented on PR #7503: URL: https://github.com/apache/camel/pull/7503#issuecomment-1111139690
> One more[ potential issue](https://github.com/apache/camel/blob/b5361d38f0d56590d151a654b11920c463beaa3b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java#L75), the map `lastProcessedOffset` seems to be read and write by different threads, It looks like it should be a `ConcurrentHashMap` I think we could try to remove this altogether and move its functionality to the commit manager. This is a remainder for the earlier versions of this component (pre 3.7), so I believe what it is trying to do overlaps with what we have there. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
