Mirror-maker 2 不复制旧数据

Question

我有 2 个 MSK kafka 集群 A 和 B 。我想使用 MM2 将数据从 A 复制到 B 。它复制新数据，但旧数据不会从 a 复制到 B 。 MM2 配置文件 -

A.bootstrap.servers=<A broker url>
B.bootstrap.servers=<B broker url>

A->B.enabled=true
topics = .*
groups = .*
A.config.storage.replication.factor=3
B.config.storage.replication.factor=3

A.offset.storage.replication.factor=3
B.offset.storage.replication.factor=3

A.status.storage.replication.factor=3
B.status.storage.replication.factor=3

offset-syncs.topic.replication.factor=3
heartbeats.topic.replication.factor=3
checkpoints.topic.replication.factor=3


replication.policy.class = org.apache.kafka.connect.mirror.IdentityReplicationPolicy
tasks.max=10
replication.factor=3
refresh.topics.enabled=true
sync.topic.configs.enabled=true
refresh.topics.interval.seconds=20

#topics.blacklist=.*[\-\.]internal, .*\.replica, __consumer_offsets
#groups.blacklist=console-consumer-.*, connect-.*, __.*
A->B.emit.heartbeats.enabled=true
A->B.emit.checkpoints.enabled=true
B->A.emit.heartbeats.enabled=true
B->A.emit.checkpoints.enabled=true

sync.group.offsets.enabled=true
sync.group.offsets.interval.seconds=60


B.security.protocol=SSL
B.ssl.truststore.location=/home/ubuntu/tls/ap-southeast-2-ci-stg/kafka.client.truststore.jks
B.ssl.keystore.location=/home/ubuntu/tls/ap-southeast-2-ci-stg/kafka.client.keystore.jks
B.ssl.keystore.password=
B.ssl.key.password=

有人可以帮忙吗？