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)

Reply via email to