

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

# 在目标集群区域使用 AWS 控制台创建复制器
<a name="msk-replicator-create-console"></a>

以下部分介绍了创建复制器的分步控制台工作流。

**复制器详细信息**

1. [在您的目标 MSK 集群所在的 AWS 区域，在家中打开 Amazon MSK 控制台？https://console.aws.amazon.com/msk/ region=us](https://console.aws.amazon.com/msk/home?region=us-east-1#/home/)-east-1\$1/home/。

1. 选择**复制器**以显示账户中的复制器列表。

1. 选择**创建复制器**。

1. 在**复制器详细信息**窗格中，为新的复制器指定一个唯一的名称。

## 选择源集群
<a name="msk-replicator-create-console-choose-source"></a>

源集群包含要复制到目标 MSK 集群的数据。

1. 在**源集群**窗格中，选择源集群所在的 AWS 区域。

   您可以通过前往 **MSK 集群**并查看**集群**详情 ARN 来查找集群的区域。区域名称嵌入在 ARN 字符串中。在以下示例 ARN 中，`ap-southeast-2` 位于集群区域中。

   ```
   arn:aws:kafka:ap-southeast-2:123456789012:cluster/cluster-11/eec93c7f-4e8b-4baf-89fb-95de01ee639c-s1
   ```

1. 输入您的源集群 ARN，或浏览以选择您的源集群。

1. 为您的源集群选择子网。

   控制台显示源集群区域中可用的子网供您选择。必须至少选择两个子网。对于同区域的 MSK 复制器，您选择的用于访问源集群的子网和用于访问目标集群的子网必须位于同一个可用区中。

1. 为 MSK 复制器选择安全组以访问您的源集群。
   + 对于跨区域复制（CRR），您不需要为源集群提供安全组。
   + 对于同区域复制 (SRR)，请转到位于的 Amazon EC2 控制台， https://console.aws.amazon.com/ec2/并确保您将为 Replicator 提供的安全组具有出站规则，允许流量进入源集群的安全组。此外，确保源集群的安全组具有入站规则允许来自为源提供的复制器安全组的流量。

      

**要将入站规则添加到源集群的安全组：**

     1. 在 AWS 控制台中，选择集群**名称，进入源集群**的详细信息。

     1. 选择**属性**选项卡，然后向下滚动到**网络设置**窗格，以选择所应用的**安全组**名称。

     1. 转到入站规则，然后选择**编辑入站规则**。

     1. 选择**添加规则**。

     1. 在新规则的**类型**列中，选择**自定义 TCP**。

     1. 在**端口范围**列中，键入 `9098`。MSK 复制器使用 IAM 访问控制连接到使用端口 9098 的集群。

     1. 在**源**列中，键入您将在为源集群创建 复制器期间提供的安全组的名称（这可能与 MSK 源集群的安全组相同），然后选择**保存规则**。

      

**要将出站规则添加到为源提供的复制器安全组：**

     1. 在 Amazon EC2 的 AWS 控制台中，转到您在为源创建复制器时将提供的安全组。

     1. 转到出站规则，然后选择**编辑出站规则**。

     1. 选择**添加规则**。

     1. 在新规则的**类型**列中，选择**自定义 TCP**。

     1. 在**端口范围**列中，键入 `9098`。MSK 复制器使用 IAM 访问控制连接到使用端口 9098 的集群。

     1. 在**源**列中，键入 MSK 源集群的安全组的名称，然后选择**保存规则**。

**注意**  
或者，如果不想使用安全组限制流量，则可以添加允许所有流量的入站和出站规则。  
1. 选择**添加规则**。  
2. 选择**类型**列中的**所有流量**。  
3. 在“源”列中，键入 `0.0.0.0/0`，然后选择**保存规则**。

## 选择目标集群
<a name="msk-replicator-create-console-choose-target"></a>

目标集群是源数据复制到的 MSK 预置集群或无服务器集群。

**注意**  
MSK 复制器在目标集群中创建新主题，并在主题名称中添加自动生成的前缀。例如，MSK 复制器将“`topic`”中的数据从源集群复制到目标集群中名为 `<sourceKafkaClusterAlias>.topic` 的新主题。这是为了将包含从源集群复制的数据的主题与目标集群中的其他主题区分开来，并避免在集群之间循环复制数据。您可以使用 `DescribeReplicator` API 或 MSK 控制台上的 **Replicator 详细信息**页面在 “**sourceKafkaCluster别名**” 字段下找到将添加到目标集群中主题名称的前缀。目标集群中的前缀是 `<sourceKafkaClusterAlias>`。

1. 在**目标集群**窗格中，选择目标集群所在的 AWS 区域。

1. 输入目标集群的 ARN 或浏览以选择目标集群。

1. 为目标集群选择子网。

   控制台显示目标集群区域中可用的子网供您选择。至少选择两个子网。

1. 为 MSK 复制器选择安全组以访问您的目标集群。

   将显示目标集群区域中可用的安全组供您选择。所选安全组与每个连接相关联。有关使用安全组的更多信息，请参阅 *Amazon VPC 用户指南*中的[使用安全组控制 AWS 资源流量](https://docs.aws.amazon.com/vpc/latest/userguide/vpc-security-groups.html)。
   + 对于跨区域复制 (CRR) 和同区域复制 (SRR)，请访问位于的 Amazon EC2 控制台，[https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/)并确保您将提供给 Replicator 的安全组具有出站规则，允许流量进入目标集群的安全组。此外，请确保目标集群的安全组具有入站规则，以接受来自为目标提供的复制器安全组的流量。

      

**要将入站规则添加到目标集群的安全组：**

     1. 在 AWS 控制台中，选择集群**名称，进入目标集群**的详细信息。

     1. 选择**属性**选项卡，然后向下滚动到“网络设置”窗格，以选择所应用的**安全组**名称。

     1. 转到入站规则，然后选择**编辑入站规则**。

     1. 选择**添加规则**。

     1. 在新规则的**类型**列中，选择**自定义 TCP**。

     1. 在**端口范围**列中，键入 `9098`。MSK 复制器使用 IAM 访问控制连接到使用端口 9098 的集群。

     1. 在**源**列中，键入您将在为目标集群创建复制器期间提供的安全组的名称（这可能与 MSK 目标集群的安全组相同），然后选择**保存规则**。

      

**要将出站规则添加到为目标提供的复制器安全组：**

     1. 在 AWS 控制台中，转到您将在为目标创建 Replicator 期间提供的安全组。

     1. 选择**属性**选项卡，然后向下滚动到“网络设置”窗格，以选择所应用的**安全组**名称。

     1. 转到出站规则，然后选择**编辑出站规则**。

     1. 选择**添加规则**。

     1. 在新规则的**类型**列中，选择**自定义 TCP**。

     1. 在**端口范围**列中，键入 `9098`。MSK 复制器使用 IAM 访问控制连接到使用端口 9098 的集群。

     1. 在**源**列中，键入 MSK 目标集群的安全组的名称，然后选择**保存规则**。

**注意**  
或者，如果不想使用安全组限制流量，则可以添加允许所有流量的入站和出站规则。  
1. 选择**添加规则**。  
2. 选择**类型**列中的**所有流量**。  
3. 在“源”列中，键入 `0.0.0.0/0`，然后选择**保存规则**。

## 配置复制器设置和权限
<a name="msk-replicator-create-settings"></a>

1. 在**复制器设置**窗格中，使用允许和拒绝列表中的正则表达式指定要复制的主题。默认情况下会复制所有主题。
**注意**  
MSK 复制器仅按排序顺序复制最多 750 个主题。如果需要复制更多主题，我们建议您创建一个单独的复制器。如果您需要为每个 Replicator 提供超过 750 个主题的[支持，请前往 AWS 控制台 Support Center 并创建支持案例](https://console.aws.amazon.com/support/home#/)。您可以使用 “TopicCount” 指标监控正在复制的主题数量。请参阅[Amazon MSK 标准代理配额](limits.md#msk-provisioned-quota)。

1. 默认情况下，MSK 复制器从选定主题中的*最新*偏移量开始复制。或者，如果您想复制主题上的现有数据，则可以从选定主题中*最早*（最旧）偏移量开始复制。一旦创建了复制器，您就无法更改此设置。此设置对应于[https://docs.aws.amazon.com/msk/1.0/apireference-replicator/v1-replicators.html#CreateReplicator](https://docs.aws.amazon.com/msk/1.0/apireference-replicator/v1-replicators.html#CreateReplicator)请求和[https://docs.aws.amazon.com/msk/1.0/apireference-replicator/v1-replicators-replicatorarn.html#DescribeReplicator](https://docs.aws.amazon.com/msk/1.0/apireference-replicator/v1-replicators-replicatorarn.html#DescribeReplicator)响应中的[https://docs.aws.amazon.com/msk/1.0/apireference-replicator/v1-replicators-replicatorarn.html#v1-replicators-replicatorarn-model-replicationstartingposition](https://docs.aws.amazon.com/msk/1.0/apireference-replicator/v1-replicators-replicatorarn.html#v1-replicators-replicatorarn-model-replicationstartingposition)字段 APIs。

1. 选择主题名称配置：
   + `PREFIXED` 主题名称复制（在控制台中**为主题名称添加前缀**）：默认设置。MSK 复制器将“topic1”从源集群复制到目标集群中名为 `<sourceKafkaClusterAlias>.topic1` 的新主题。
   + 相同主题名称复制（控制台中为**保留相同的主题名称**）：来自源集群的主题在目标集群中以相同的主题名称进行复制。

   此设置对应于`CreateReplicator`请求和`DescribeReplicator`响应中的`TopicNameConfiguration`字段 APIs。请参阅[Amazon MSK 复制器的工作原理](msk-replicator-how-it-works.md)。
**注意**  
默认情况下，MSK 复制器在目标集群中创建新主题，并在主题名称中添加自动生成的前缀。这是为了将包含从源集群复制的数据的主题与目标集群中的其他主题区分开来，并避免在集群之间循环复制数据。或者，您可以创建具有相同主题名称复制（控制台中为**保留相同的主题名称**）的 MSK 复制器，以便在复制期间保留主题名称。此配置减少了您在设置期间重新配置客户端应用程序的需要，并使操作多集群流架构变得更加简单。

1. 默认情况下，MSK Replicator 会复制所有元数据，包括主题配置、访问控制列表 (ACLs) 和使用者组偏移量，以实现无缝故障转移。如果您创建的不是用于失效转移的复制器，则可以选择关闭**其他设置**部分中提供的一个或多个设置。
**注意**  
MSK Replicator 不会复制写入， ACLs 因为您的制作者不应直接写入目标集群中复制的主题。失效转移后，您的生成器应写入目标集群中的本地主题。有关详细信息，请参阅 [按计划向辅助 AWS 区域执行故障转移](msk-replicator-perform-planned-failover.md)。

1. 在**使用器组复制**窗格中，使用允许和拒绝列表中的正则表达式指定要复制的主题。默认情况下，所有使用器组都会被复制。

1. 在**压缩**窗格中，您可以选择压缩写入目标集群的数据。如果您要使用压缩，我们建议您使用与源集群中的数据相同的压缩方法。

1. 在**访问权限**窗格中，执行以下任一操作：

   1. 选择**创建或更新具有所需策略的 IAM 角色**。MSK 控制台将自动为服务执行角色附加必要的权限和信任策略，以便读取和写入您的源和目标 MSK 集群。  
![\[用于创建或更新复制器 IAM 角色的 MSK 控制台\]](http://docs.aws.amazon.com/zh_cn/msk/latest/developerguide/images/msk-replicator-ezCRC.png)

   1. 通过选择**从 Amazon MSK 可以代入的 IAM 角色中选择**提供您自己的 IAM 角色。我们建议您将 `AWSMSKReplicatorExecutionRole` 托管的 IAM 策略附加到您的服务执行角色，而不是编写您自己的 IAM 策略。

      1. 创建 IAM 角色，复制器将使用该角色对源和目标 MSK 集群进行读取和写入操作，并使用以下 JSON 作为信任策略的一部分，并将 `AWSMSKReplicatorExecutionRole` 附加到该角色。在信任策略中，将占位符 <yourAccountID> 替换为您的实际账户 ID。

------
#### [ JSON ]

****  

        ```
        {
            "Version":"2012-10-17",		 	 	 
            "Statement": [
                {
                    "Effect": "Allow",
                    "Principal": {
                        "Service": "kafka.amazonaws.com"
                    },
                    "Action": "sts:AssumeRole",
                    "Condition": {
                        "StringEquals": {
                            "aws:SourceAccount": "<yourAccountID>"
                        }
                    }
                }
            ]
        }
        ```

------

1. 在**复制器标签**窗格中，您可以选择为 MSK 复制器资源分配标签。有关更多信息，请参阅 [为 Amazon MSK 集群添加标签](msk-tagging.md)。对于跨区域 MSK 复制器，在创建复制器时，标签会自动同步到远程区域。如果在创建复制器后更改标签，则更改不会自动同步到远程区域，因此您需要手动同步本地复制器和远程复制器参考。

1. 选择**创建**。

如果想要限制 `kafka-cluster:WriteData` 权限，请参阅 [How IAM access control for Amazon MSK works](https://docs.aws.amazon.com/msk/latest/developerguide/iam-access-control.html#how-to-use-iam-access-control) 中的 *Create authorization policies* 部分。您需要为源集群和目标集群添加 `kafka-cluster:WriteDataIdempotently` 权限。

大约需要 30 分钟才能成功创建 MSK 复制器并转换到 RUNNING 状态。

如果您创建一个新的 MSK 复制器来替换已删除的复制器，则新的复制器会从最新的偏移开始复制。

如果您的 MSK 复制器已转换为 FAILED 状态，请参阅问题排查部分[排查 MSK 复制器的问题](msk-replicator-troubleshooting.md)。