翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
# ターゲットクラスターリージョンで AWS コンソールを使用してレプリケーターを作成する
次のセクションでは、レプリケーターを作成するためのステップごとのコンソールワークフローについて説明します。
**レプリケーターの詳細**
1. ターゲット MSK クラスターがある AWS リージョンで、[https://console.aws.amazon.com/msk/home?region=us-east-1\$1/home/](https://console.aws.amazon.com/msk/home?region=us-east-1#/home/) で Amazon MSK コンソールを開きます。
1. **[レプリケーター]** を選択すると、アカウント内のレプリケーターのリストが表示されます。
1. **[レプリケータの作成]** を選択します。
1. **[レプリケータの詳細]** ペインで、新しいレプリケーターに一意の名前を付けます。
## ソースクラスターの選択
ソースクラスターには、ターゲット 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. ソースクラスターのサブネットを選択します。
コンソールには、ソースクラスターのリージョンで使用可能なサブネットが表示され、そこから選択できます。少なくとも 2 つのサブネットを選択する必要があります。同一リージョン MSK レプリケーターの場合、ソースクラスターにアクセスするために選択するサブネットと、ターゲットクラスターにアクセスするためのサブネットが、同じアベイラビリティーゾーンにある必要があります。
1. MSK レプリケーターがソースクラスターにアクセスするためのセキュリティグループを選択します。
+ クロスリージョンレプリケーション (CRR) の場合、ソースクラスターのセキュリティグループを指定する必要はありません。
+ 同一リージョンレプリケーション (SRR) の場合は、Amazon EC2 コンソール (https://console.aws.amazon.com/ec2/) にアクセスし、レプリケーター用に指定するセキュリティグループに、ソースクラスターのセキュリティグループへのトラフィックを許可するアウトバウンドルールがあることを確認します。同様に、ソースクラスターのセキュリティグループに、ソース用に指定したレプリケーターセキュリティグループからのトラフィックを許可するインバウンドルールがあることを確認します。
**ソースクラスターのセキュリティグループにインバウンドルールを追加するには**
1. AWS コンソールで、クラスター**名を選択してソースクラスター**の詳細に移動します。
1. **[プロパティ]** タブを選択し、**[ネットワーク設定]** ペインまで下にスクロールして、適用する**セキュリティグループ**の名前を選択します。
1. インバウンドルールに移動し、**[インバウンドルールの編集]** を選択します。
1. **[Add rule]** (ルールを追加) を選択します。
1. 新しいルールの **[タイプ]** 列で、**[カスタム TCP]** を選択します。
1. **[ポート範囲]** 列に「`9098`」と入力します。MSK Replicator は IAM アクセスコントロールを使用して、9098 番ポートを使用するクラスターに接続します。
1. **[ソース]** 列に、レプリケーター作成時にソースクラスター用に指定するセキュリティグループの名前 (これは、MSK ソースクラスターのセキュリティグループと同じになる場合があります) を入力し、**[ルールの保存]** を選択します。
**ソース用に指定したレプリケーターのセキュリティグループにアウトバウンドルールを追加するには**
1. Amazon EC2 の AWS コンソールで、ソースのレプリケーターの作成時に指定するセキュリティグループに移動します。
1. アウトバウンドルールに移動し、**[アウトバウンドルールの編集]** を選択します。
1. **[Add rule]** (ルールを追加) を選択します。
1. 新しいルールの **[タイプ]** 列で、**[カスタム TCP]** を選択します。
1. **[ポート範囲]** 列に「`9098`」と入力します。MSK Replicator は IAM アクセスコントロールを使用して、9098 番ポートを使用するクラスターに接続します。
1. **[ソース]** 列に、MSK ソースクラスターのセキュリティグループの名前を入力し、**[ルールの保存]** を選択します。
**注記**
あるいは、セキュリティグループを使用したトラフィックの制限を希望しない場合は、すべてのトラフィックを許可するインバウンドルールとアウトバウンドルールを追加できます。
1. **[Add rule]** (ルールを追加) を選択します。
2. **[タイプ]** 列で **[すべてのトラフィック]** を選択します。
3. [ソース] 列に `0.0.0.0/0` と入力し、**[ルールの保存]** を選択します。
## ターゲットクラスターの選択
ターゲットクラスターは、ソースデータのコピー先となる、MSK プロビジョンドクラスターまたはサーバーレスクラスターです。
**注記**
MSK レプリケーターは、ターゲットクラスターに新しいトピックを作成し、自動生成されたプレフィックスをトピック名に追加します。例えば、MSK レプリケーターは、ソースクラスターの「`topic`」内のデータをターゲットクラスターの `.topic` という名前の新しいトピックにレプリケートします。これは、ソースクラスターからレプリケートされたデータを含むトピックを、ターゲットクラスターの他のトピックと区別し、データがクラスター間で循環的にレプリケートされないようにするためです。ターゲットクラスターでトピック名に追加されるプレフィックスは、`DescribeReplicator` API を使用して **sourceKafkaClusterAlias** フィールドで確認するか、または MSK コンソールの **[レプリケータの詳細]** ページで確認することができます。ターゲットクラスターのプレフィックスは `` です。
1. **ターゲットクラスター**ペインで、ターゲットクラスターがある AWS リージョンを選択します。
1. ターゲットクラスターの ARN を入力するか、参照してターゲットクラスターを選択します。
1. ターゲットクラスターのサブネットを選択します。
コンソールには、ターゲットクラスターのリージョンで使用可能なサブネットが表示され、そこから選択できます。少なくとも 2 つのサブネットを選択します。
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/)) にアクセスし、レプリケーター用に指定するセキュリティグループに、ターゲットクラスターのセキュリティグループへのトラフィックを許可するアウトバウンドルールがあることを確認します。また、ターゲットクラスターのセキュリティグループに、ターゲット用に指定されたレプリケーターセキュリティグループからのトラフィックを受け入れるインバウンドルールがあることを確認します。
**ターゲットクラスターのセキュリティグループにインバウンドルールを追加するには**
1. AWS コンソールで、クラスター**名を選択してターゲットクラスター**の詳細に移動します。
1. **[プロパティ]** タブを選択し、[ネットワーク設定] ペインまで下にスクロールして、適用する**セキュリティグループ**の名前を選択します。
1. インバウンドルールに移動し、**[インバウンドルールの編集]** を選択します。
1. **[Add rule]** (ルールを追加) を選択します。
1. 新しいルールの **[タイプ]** 列で、**[カスタム TCP]** を選択します。
1. **[ポート範囲]** 列に「`9098`」と入力します。MSK Replicator は IAM アクセスコントロールを使用して、9098 番ポートを使用するクラスターに接続します。
1. **[ソース]** 列に、レプリケーター作成時にターゲットクラスター用に指定するセキュリティグループの名前 (これは、MSK ターゲットクラスターのセキュリティグループと同じになる場合があります) を入力し、**[ルールの保存]** を選択します。
**ターゲット用に指定したレプリケーターのセキュリティグループにアウトバウンドルールを追加するには**
1. AWS コンソールで、ターゲットのレプリケーターの作成時に指定するセキュリティグループに移動します。
1. **[プロパティ]** タブを選択し、[ネットワーク設定] ペインまで下にスクロールして、適用する**セキュリティグループ**の名前を選択します。
1. アウトバウンドルールに移動し、**[アウトバウンドルールの編集]** を選択します。
1. **[Add rule]** (ルールを追加) を選択します。
1. 新しいルールの **[タイプ]** 列で、**[カスタム TCP]** を選択します。
1. **[ポート範囲]** 列に「`9098`」と入力します。MSK Replicator は IAM アクセスコントロールを使用して、9098 番ポートを使用するクラスターに接続します。
1. **[ソース]** 列で、MSK ターゲットクラスターのセキュリティグループの名前を入力し、**[ルールの保存]** を選択します。
**注記**
あるいは、セキュリティグループを使用したトラフィックの制限を希望しない場合は、すべてのトラフィックを許可するインバウンドルールとアウトバウンドルールを追加できます。
1. **[Add rule]** (ルールを追加) を選択します。
2. **[タイプ]** 列で **[すべてのトラフィック]** を選択します。
3. [ソース] 列に `0.0.0.0/0` と入力し、**[ルールの保存]** を選択します。
## レプリケータの設定とアクセス許可を設定します。
1. **[レプリケータ設定]** ペインで、レプリケートするトピックを、正規表現を使用して許可リストと拒否リストに指定します。デフォルトでは、すべてのトピックがレプリケートされます。
**注記**
MSK Replicator は、ソート順に最大 750 のトピックのみをレプリケートします。より多くのトピックをレプリケートする必要がある場合は、別のレプリケーターを作成することをお勧めします。レプリケーターあたり 750 を超えるトピックのサポートが必要な場合は、 AWS コンソールサポートセンターに移動し[、サポートケースを作成します](https://console.aws.amazon.com/support/home#/)。レプリケートされるトピックの数は、「TopicCount」メトリクスを使用してモニタリングできます。「[Amazon MSK 標準 ブローカークォータ](limits.md#msk-provisioned-quota)」を参照してください。
1. デフォルトでは、MSK Replicator は、選択したトピックの*最も新しい*オフセットからレプリケーションを開始します。あるいは、トピックの既存のデータをレプリケートする場合は、選択したトピックの*最も古い*オフセットからレプリケーションを開始できます。レプリケーターが作成されると、この設定を変更することはできません。この設定は、 リクエスト[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) API および レスポンス API の [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)フィールドに対応[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)します。
1. トピック名の設定を選択します。
+ `PREFIXED` トピック名レプリケーション (コンソールで**トピック名にプレフィックスを追加**): デフォルト設定。MSK Replicator は、ソースクラスターの「topic1」をターゲットクラスター内の新しいトピックに `.topic1` という名前でレプリケートします。
+ 同一トピック名レプリケーション (コンソールで**同じトピック名を保持**): ソースクラスターのトピックは、ターゲットクラスターに同一のトピック名でレプリケートされます。
この設定は、`CreateReplicator` リクエスト API と `DescribeReplicator` レスポンス API の `TopicNameConfiguration` フィールドに対応します。「[Amazon MSK Replicator の仕組み](msk-replicator-how-it-works.md)」を参照してください。
**注記**
デフォルトでは、MSK Replicator は、自動生成されたプレフィックスをトピック名に追加した新しいトピックをターゲットクラスターに作成します。これは、ソースクラスターからレプリケートされたデータを含むトピックを、ターゲットクラスターの他のトピックと区別し、データがクラスター間で循環的にレプリケートされないようにするためです。あるいは、同一トピック名レプリケーション (コンソールで**同じトピック名を保持**) を使用して MSK レプリケーターを作成し、レプリケーション中にトピック名が保持されるようにすることもできます。この設定により、セットアップ中にクライアントアプリケーションを再設定する必要性が減り、マルチクラスターストリーミングアーキテクチャの操作が簡単になります。
1. デフォルトでは、MSK レプリケーターは、トピック設定、アクセスコントロールリスト (ACL)、コンシューマーグループのオフセットを含むすべてのメタデータをコピーし、シームレスなフェイルオーバーを実現します。フェイルオーバー用にレプリケーターを作成しない場合は、オプションで、**[追加設定]** セクションで使用可能なこれらの設定の 1 つ以上を無効にすることができます。
**注記**
MSK レプリケーターは書き込み ACL をレプリケートしません。これは、プロデューサーがターゲットクラスター内のレプリケートされたトピックに直接書き込みを行えないようにするためです。プロデューサーは、フェイルオーバー後にターゲットクラスターのローカルトピックに書き込む必要があります。詳細については、「[セカンダリ AWS リージョンへの計画的なフェイルオーバーを実行する](msk-replicator-perform-planned-failover.md)」を参照してください。
1. **[コンシューマーグループのレプリケーション]** ペインで、レプリケートするコンシューマーグループを、正規表現を使用して許可リストと拒否リストに指定します。デフォルトでは、すべてのコンシューマーグループがレプリケートされます。
1. **[圧縮]** ペインでは、オプションで、ターゲットクラスターに書き込まれたデータを圧縮することを選択できます。圧縮を使用する場合は、ソースクラスターのデータと同じ圧縮方式を使用することが推奨されます。
1. **[アクセス許可]** ペインで、次のいずれかを実行します。
1. **[必要なポリシーで IAM ロールを作成または更新]** を選択します。MSK コンソールは、ソースおよびターゲット MSK クラスターに対する読み取りと書き込みに必要なサービス実行ロールに、必要なアクセス許可と信頼ポリシーを自動的にアタッチします。
![\[レプリケーター IAM ロールを作成または更新するための MSK コンソール\]](http://docs.aws.amazon.com/ja_jp/msk/latest/developerguide/images/msk-replicator-ezCRC.png)
1. **[Amazon MSK が引き受けることができる IAM ロールから選択]** を選択して、独自の IAM ロールを指定します。独自の IAM ポリシーを記述するのではなく、`AWSMSKReplicatorExecutionRole` マネージド IAM ポリシーをサービス実行ロールにアタッチすることをお勧めします。
1. 信頼ポリシーの一部として以下の JSON を使用し、ロールに `AWSMSKReplicatorExecutionRole` をアタッチして、レプリケーターがソースおよびターゲット MSK クラスターへの読み込みと書き込みに使用する IAM ロールを作成します。す。信頼ポリシー内のプレースホルダー は、実際のアカウント ID に置き換えてください。
------
#### [ JSON ]
****
```
{
"Version":"2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Principal": {
"Service": "kafka.amazonaws.com"
},
"Action": "sts:AssumeRole",
"Condition": {
"StringEquals": {
"aws:SourceAccount": ""
}
}
}
]
}
```
------
1. **[レプリケータータグ]** ペインでは、オプションで、MSK レプリケーターリソースにタグを割り当てることができます。詳細については、「[Amazon MSK クラスターをタグ付ける](msk-tagging.md)」を参照してください。クロスリージョン MSK レプリケーターの場合、タグは、レプリケーターの作成時に自動的にリモートリージョンに同期されます。レプリケーターの作成後にタグを変更しても、その変更はリモートリージョンに自動的に同期されないため、ローカルレプリケーターとリモートレプリケーターのリファレンスを手動で同期する必要があります。
1. **[作成]** を選択します。
`kafka-cluster:WriteData` アクセス許可を制限する場合は、「[Amazon MSK の IAM アクセスコントロールの仕組み](https://docs.aws.amazon.com/msk/latest/developerguide/iam-access-control.html#how-to-use-iam-access-control)」の「*承認ポリシーの作成*」セクションを参照してください。ソースクラスターとターゲットクラスターの両方に `kafka-cluster:WriteDataIdempotently` アクセス許可を追加する必要があります。
MSK レプリケーターが正常に作成され、RUNNING ステータスに移行するまでに約 30 分かかります。
削除した MSK レプリケーターを置き換えるために新しい MSK レプリケーターを作成すると、新しいレプリケーターは最新のオフセットからレプリケーションを開始します。
MSK レプリケーターが FAILED ステータスに移行した場合は、トラブルシューティングのセクション「[Troubleshooting MSK Replicator](msk-replicator-troubleshooting.md)」を参照してください。