1

我正在使用具有以下属性的 mm2 源（A），接收器（B）集群都有自己单独的动物园管理员我从源 A 中的主题测试中消耗一些数据。然后我停止了消费者，并在我将消费者指向同一组时启动镜像进程id 下沉然后它从头开始消费。我期待它应该从它在源中停止的地方开始。###############

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```
4

1 回答 1

1

从 Kafka 2.7 开始，MirrorMaker 可以通过设置sync.group.offsets.enabled=true.

在您的示例中：

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

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

于 2021-11-06T10:37:52.747 回答