Otavio Rodolfo Piske created CAMEL-18253:
--------------------------------------------
Summary: camel-kafka: idempotent repository may report incorrect
number of messages
Key: CAMEL-18253
URL: https://issues.apache.org/jira/browse/CAMEL-18253
Project: Camel
Issue Type: Task
Components: camel-kafka
Affects Versions: 3.17.0, 3.14.4
Reporter: Otavio Rodolfo Piske
Assignee: Otavio Rodolfo Piske
Any code that calls the (potentially) safe contains method on the Kafka
idempotent repository may cause it to incorrectly report an additional number
of duplicate messages because it uses incrementAndGet on the counter:
https://github.com/apache/camel/blob/camel-3.17.x/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java#L375-L382
--
This message was sent by Atlassian Jira
(v8.20.10#820010)