You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@camel.apache.org by "Claus Ibsen (Jira)" <ji...@apache.org> on 2022/07/01 10:41:00 UTC

[jira] [Commented] (CAMEL-18253) camel-kafka: idempotent repository may report incorrect number of messages

    [ https://issues.apache.org/jira/browse/CAMEL-18253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561412#comment-17561412 ] 

Claus Ibsen commented on CAMEL-18253:
-------------------------------------

Can you backport to 3.14.x branch

> 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: Bug
>          Components: camel-kafka
>    Affects Versions: 3.14.4, 3.17.0
>            Reporter: Otavio Rodolfo Piske
>            Assignee: Otavio Rodolfo Piske
>            Priority: Minor
>             Fix For: 3.18.0
>
>
> 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)