在从Mirror maker 1.0迁移到Mirror maker 2.0时维护相同的用户组

Question

试图将镜像制造者1.0升级到镜像制造者2.0，并观察到在关闭镜像制造者1.0和启动镜像制造者2.0时，消费者开始从一开始就收到消息(重复)。发现此post突出了相同的问题。

如何在镜像maker 2.0中传递consumer group name以保持镜像maker 1.0中使用的相同consumer group name？

如何在镜像制造商2.0中配置auto.offset.reset属性？

Answer 1

( a)您不能使用MM1和MM2直接重用使用者组，因为MM2不使用使用者组，而是一个Kafka连接器。

auto.offset.reset目前在MM2中是不可配置的。它将在下一个版本2.7.0中配置，预计很快就会发布(作为12月17日，对发布候选版本的投票正在进行中)。

从2.7.0开始，它将在您的配置中使用<alias>.consumer.auto.offset.reset或consumer.auto.offset.reset进行配置。