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

Greg Harris commented on KAFKA-10339:
-------------------------------------

[~funkerman] Hello!

In your example, no, because auto-synced offsets is at-least-once. If Consumer 
A reads and commits A, B, C, they may be re-read by consumer B. The guarantee 
that "MM2 EOS" provides is that consumer B will read mirrored messages at most 
once, regardless of what consumer A does.

> MirrorMaker2 Exactly-once Semantics
> -----------------------------------
>
>                 Key: KAFKA-10339
>                 URL: https://issues.apache.org/jira/browse/KAFKA-10339
>             Project: Kafka
>          Issue Type: New Feature
>          Components: KafkaConnect, mirrormaker
>            Reporter: Ning Zhang
>            Assignee: Ning Zhang
>            Priority: Major
>              Labels: needs-kip
>             Fix For: 3.5.0
>
>         Attachments: image-2023-10-17-15-33-57-983.png
>
>
> MirrorMaker2 is currently implemented on Kafka Connect Framework, more 
> specifically the Source Connector / Task, which do not provide exactly-once 
> semantics (EOS) out-of-the-box, as discussed in 
> https://github.com/confluentinc/kafka-connect-jdbc/issues/461,  
> https://github.com/apache/kafka/pull/5553, 
> https://issues.apache.org/jira/browse/KAFKA-6080  and 
> https://issues.apache.org/jira/browse/KAFKA-3821. Therefore MirrorMaker2 
> currently does not provide EOS.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to