apache-kafka Kafka MirrorMaker2自动化消费类偏移同步

s4n0splo 于 2022-11-01 发布在 Apache

关注(0)|答案(1)|浏览(210)

我正在使用MirrorMaker2进行灾难恢复。
Kafka2.7应该支持automated consumer offset sync
下面是我正在使用的yaml文件（我使用strimzi来创建它）

在目标集群中复制所有源集群主题。此外，在目标集群中创建**...checkpoint.internal主题，该主题包含同步的所有源集群偏移，但我没有看到这些偏移被转换为目标集群_consumer_offsets**主题，这意味着当我在目标集群中启动使用者（同一个使用者组）时，它将从头开始阅读消息。
我的期望是，在允许自动化消费者偏移之后，同步来自源集群的所有消费者偏移，这些偏移被转换并存储在目标集群的_consumer_offsets主题中。
有人能澄清一下我的期望是否正确吗？如果不正确，它应该如何工作？

apache-kafka

来源：https://stackoverflow.com/questions/65925842/kafka-mirrormaker2-automated-consumer-offset-sync

1条答案

按热度按时间

uqcuzwp81#

sync.group.offsets.enabled设置适用于MirrorCheckpointConnector。
我不完全确定Strimzi是如何运行MirrorMaker 2的，但我认为您需要将其设置为：

checkpointConnector:
  config:
    checkpoints.topic.replication.factor: 1
    sync.group.offsets.enabled: "true"

赞(0）回复(0）举报 2022-11-01

我来回答

apache-kafka Kafka MirrorMaker2自动化消费类偏移同步

1条答案

相关问题

热门标签

最新问答