[
https://issues.apache.org/jira/browse/KAFKA-14021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860163#comment-17860163
]
Chris Egerton commented on KAFKA-14021:
---------------------------------------
The {{MirrorSourceTask::commit}} method doesn't actually commit consumer
offsets, it only handles offset syncs (which are irrelevant here). On startup,
the task reads the last-committed offsets from the Kafka Connect offsets topic
and, based on those, seeks to the appropriate position with its consumer. It
never relies on the offsets that are committed to the {{__consumer_offsets}}
topic, it only relies on the offsets written to the internal Kafka Connect
offsets topic.
> MirrorMaker 2 should implement KIP-618 APIs
> -------------------------------------------
>
> Key: KAFKA-14021
> URL: https://issues.apache.org/jira/browse/KAFKA-14021
> Project: Kafka
> Issue Type: Improvement
> Components: connect, mirrormaker
> Reporter: Chris Egerton
> Assignee: Chris Egerton
> Priority: Major
> Fix For: 3.5.0
>
>
> The {{MirrorSourceConnector}} class should implement the new APIs added by
> KIP-618.
> This includes the
> [SourceConnector::exactlyOnceSupport|https://github.com/apache/kafka/blob/025e47b8334eb7125c7fdd2f725a2fef3c98344c/connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java#L34-L54]
> method and, potentially, the
> [SourceConnector::canDefineTransactionBoundaries|https://github.com/apache/kafka/blob/025e47b8334eb7125c7fdd2f725a2fef3c98344c/connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java#L56-L73]
> method.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
