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

Reply via email to