Ning Zhang created KAFKA-9076: --------------------------------- Summary: MirrorMaker 2.0 automated consumer offset sync Key: KAFKA-9076 URL: https://issues.apache.org/jira/browse/KAFKA-9076 Project: Kafka Issue Type: Improvement Components: mirrormaker Affects Versions: 2.4.0 Reporter: Ning Zhang Fix For: 2.5.0
To calculate the translated consumer offset in the target cluster, currently `Mirror-client` provides a function called "remoteConsumerOffsets()" that is used by "RemoteClusterUtils" for one-time purpose. In order to make the consumer migration from source to target cluster transparent and convenient, e.g. in event of source cluster failure, it is better to have a background job to continuously and periodically sync the consumer offsets from the source to target cluster, so that when the consumer switches to the target cluster, it will resume to consume from where it left off at source cluster. -- This message was sent by Atlassian Jira (v8.3.4#803005)