0

试图将mirror maker 1.0升级到mirror maker 2.0，并观察到在关闭mirror maker 1.0并启动mirror maker 2.0时，消费者从一开始就开始收到消息（重复）。发现这篇文章强调了同样的问题。
一个。如何通过consumer group namein mirror maker 2.0 以保持与consumer group name在 mirror maker 1.0 中使用的相同？
湾。auto.offset.resetmirror maker 2.0如何配置属性？

4

1 回答 1

1

a）您不能直接使用 MM2 重用来自 MM1 的消费者组，因为 MM2 不使用消费者组，它是一个 Kafka Connect 连接器。

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

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

于 2020-12-17T19:00:10.597 回答