从 Mirror maker 1.0 迁移到 Mirror maker 2.0 时保持相同的消费者组
Maintaining same consumer group while migrating from Mirror maker 1.0 to Mirror maker 2.0
正在尝试将 Mirror maker 1.0 升级到 Mirror maker 2.0,并观察到在关闭 Mirror maker 1.0 并启动 Mirror maker 2.0 时,消费者开始从头开始接收消息(重复)。发现这个 强调了同样的问题。
一种。如何在 mirror maker 2.0 中传递 consumer group name
以保持与 mirror maker 1.0 中使用的 consumer group name
相同?
b. auto.offset.reset
属性镜像制作器2.0如何配置?
a) 您不能直接将 MM1 的消费者组与 MM2 重用,因为 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
进行配置。
正在尝试将 Mirror maker 1.0 升级到 Mirror maker 2.0,并观察到在关闭 Mirror maker 1.0 并启动 Mirror maker 2.0 时,消费者开始从头开始接收消息(重复)。发现这个
一种。如何在 mirror maker 2.0 中传递 consumer group name
以保持与 mirror maker 1.0 中使用的 consumer group name
相同?
b. auto.offset.reset
属性镜像制作器2.0如何配置?
a) 您不能直接将 MM1 的消费者组与 MM2 重用,因为 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
进行配置。