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
