Skip to main content

Can I tell mirrormaker2 to start (re)consuming from a specific offset?

Hi everyone,

I am using Mirrormaker 2. From what I understand, mirrormaker2 does not store its offsets in the source cluster's __consumer_offsets topic. Rather, it stores its offsets in the destination cluster in the value defined by offset.storage.topic

In the __consumer_offsets world, I could manually change offsets by doing this
kafka-consumer-groups.sh --bootstrap-server kafka:9092 --group groupname --reset-offsets --to-latest--execute

Is there any similar way to manipulate mirrormaker2, to tell it to start (re)consuming from a specific offset in a source topic?

Thanks,
-James

Comments