Was trying to upgrade mirror maker 1.0 to mirror maker 2.0 and observed that on shutting down mirror maker 1.0 and starting mirror maker 2.0 the consumer starts getting messages from the beginning(duplicates). Found this post highlighting the same issue.
a. How to pass the consumer group name in mirror maker 2.0 to keep the same consumer group name as being used in mirror maker 1.0?
b. How to configure the auto.offset.reset property in mirror maker 2.0?
0
votes
1 Answers
1
votes
a) You can't directly reuse the consumer group from MM1 with MM2 because MM2 does not use a consumer group, it's a Kafka Connect connector.
b) auto.offset.reset is not currently configurable in MM2. It will be configurable in the next release, 2.7.0, which is expected to release very soon (as a Dec 17, a vote on the release candidate is on-going).
From 2.7.0, it will be configurable using <alias>.consumer.auto.offset.reset or consumer.auto.offset.reset in your configuration.
