本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

# 使用 MSK 复制器创建主动-主动设置
<a name="msk-replicator-active-active"></a>

如果您想要创建一个主动-主动设置，其中两个 MSK 集群都积极地提供读写服务，我们建议您使用具有带前缀主题名称复制（控制台中为**为主题名称添加前缀**）的 MSK 复制器。但是，这将要求您重新配置消费者来读取复制的主题。

按照以下步骤在源 MSK 集群 A 和目标 MSK 集群 B 之间设置主动-主动拓扑。

1. 创建 MSK 复制器，将 MSK 集群 A 作为源，将 MSK 集群 B 作为目标。

1. 成功创建上述 MSK 复制器后，创建一个以集群 B 为源、集群 A 为目标的复制器。

1. 创建两组生成器，每组生成器将数据同时写入与生成器位于同一区域的集群中的本地主题（例如“主题”）。

1. 创建两组使用者，每组使用通配符订阅读取数据（例如”。 \$1topic”) 来自与消费者位于同一 AWS 区域的 MSK 集群。这样，您的使用器将自动从本地主题（例如 `topic`）读取在该区域本地生成的数据，以及从主题中带有 `<sourceKafkaClusterAlias>.topic` 前缀的其他区域复制的数据。这两组使用者应具有不同的使用者组， IDs 这样当 MSK Replicator 将它们复制到另一个集群时，消费者组偏移量就不会被覆盖。

如果想要避免重新配置客户端，可以使用相同主题名称复制（控制台中为**保留相同的主题名称**）创建 MSK 复制器来创建主动-主动设置，而不是使用带前缀主题名称复制（控制台中为**为主题名称添加前缀**）。但是，您将为每个复制器支付额外的数据处理和数据传输费用。这是因为每个复制器需要处理两倍于平时的数据量，一次用于复制，另一次用于防止无限循环。您可以使用 `ReplicatorBytesInPerSec` 指标跟踪每个复制器处理的总数据量。请参阅[监控复制](msk-replicator-monitor.md)。此指标包括复制到目标集群的数据以及由 MSK 复制器筛选的数据，以防止数据被复制回其来源的同一主题。

**注意**  
如果使用相同主题名称复制（控制台中为**保留相同的主题名称**）来设置主动-主动拓扑，请在删除主题后至少等待 30 秒，然后再重新创建同名主题。此等待期有助于防止重复的消息被复制回源集群。您的使用器必须能够在不影响下游的情况下重新处理重复的消息。请参阅[构建多区域 Apache Kafka 应用程序的注意事项](msk-replicator-increase-resiliency.md#msk-replication-multi-region-kafka-applications)。