__consumer_offset无法同步

Question

我正在使用具有以下属性的源( A )，宿(B)集群，它们都有自己的单独的zookeeper。我在源A中消耗来自主题测试的一些数据。然后我停止了mm2，并在我将具有相同组id的consumer指向汇点时启动镜像进程，然后它开始从头开始消费。我希望它应该从源码中停止的地方开始。#

A.bootstrap.servers = localhost:9092
B.bootstrap.servers = localhost:9093
A->B.enabled = true
A->B.topics = test
#B->A.enabled = true
#B->A.topics = .*
checkpoints.topic.replication.factor=1
heartbeats.topic.replication.factor=1
offset-syncs.topic.replication.factor=1
offset.storage.replication.factor=1
status.storage.replication.factor=1
config.storage.replication.factor=1```

Answer 1

从Kafka 2.7开始，MirrorMaker可以通过设置sync.group.offsets.enabled=true自动镜像消费者组偏移量。

在您的示例中：

A->B.sync.group.offsets.enabled=true

在2.7之前，MirrorMaker不会自动提交消费者组偏移量，您需要使用RemoteClusterUtils进行偏移量转换。