Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

# Buat replikator menggunakan CLI AWS
<a name="msk-replicator-create-cli"></a>

Gunakan `create-replicator` perintah untuk membuat replikator MSK. Sebelum Anda mulai, pastikan Anda memiliki [Izin IAM diperlukan untuk membuat Replikator MSK](msk-replicator-create-iam-perms.md) dan telah menyelesaikannya[Siapkan cluster sumber dan target](msk-replicator-prepare-clusters.md).

**catatan**  
Contoh di bawah ini menunjukkan replikasi antara dua cluster MSK. MSK Replicator juga mendukung replikasi antara cluster Apache Kafka yang dikelola sendiri dan cluster MSK Provisioned dengan broker Express. Untuk contoh API yang mencakup skenario tersebut, lihat[CreateReplicator Contoh API untuk cluster Kafka yang dikelola sendiri](msk-replicator-external-api-examples.md).

```
aws kafka create-replicator \
  --replicator-name "<replicator-name>" \
  --service-execution-role-arn "arn:aws:iam::<account-id>:role/<role-name>" \
  --kafka-clusters '[
    {
      "AmazonMskCluster": {"MskClusterArn": "<source-cluster-arn>"},
      "VpcConfig": {
        "SubnetIds": ["<subnet-1>", "<subnet-2>"],
        "SecurityGroupIds": ["<security-group-id>"]
      }
    },
    {
      "AmazonMskCluster": {"MskClusterArn": "<target-cluster-arn>"},
      "VpcConfig": {
        "SubnetIds": ["<subnet-1>", "<subnet-2>"],
        "SecurityGroupIds": ["<security-group-id>"]
      }
    }
  ]' \
  --replication-info-list '[
    {
      "SourceKafkaClusterArn": "<source-cluster-arn>",
      "TargetKafkaClusterArn": "<target-cluster-arn>",
      "TopicReplication": {
        "TopicsToReplicate": [".*"],
        "CopyTopicConfigurations": true,
        "CopyAccessControlListsForTopics": true,
        "DetectAndCopyNewTopics": true,
        "StartingPosition": {"Type": "LATEST"},
        "TopicNameConfiguration": {"Type": "PREFIXED"}
      },
      "ConsumerGroupReplication": {
        "ConsumerGroupsToReplicate": [".*"],
        "ConsumerGroupOffsetSyncMode": "LEGACY"
      },
      "TargetCompressionType": "NONE"
    }
  ]'
```

Untuk mengaktifkan pengiriman log saat membuat replikator, sertakan `--log-delivery` parameternya. Contoh berikut memungkinkan pengiriman log ke Amazon CloudWatch Logs, Amazon S3, dan Amazon Data Firehose.

```
aws kafka create-replicator \
  --replicator-name "<replicator-name>" \
  --service-execution-role-arn "arn:aws:iam::<account-id>:role/<role-name>" \
  --kafka-clusters '[
    {
      "AmazonMskCluster": {"MskClusterArn": "<source-cluster-arn>"},
      "VpcConfig": {
        "SubnetIds": ["<subnet-1>", "<subnet-2>"],
        "SecurityGroupIds": ["<security-group-id>"]
      }
    },
    {
      "AmazonMskCluster": {"MskClusterArn": "<target-cluster-arn>"},
      "VpcConfig": {
        "SubnetIds": ["<subnet-1>", "<subnet-2>"],
        "SecurityGroupIds": ["<security-group-id>"]
      }
    }
  ]' \
  --replication-info-list '[
    {
      "SourceKafkaClusterArn": "<source-cluster-arn>",
      "TargetKafkaClusterArn": "<target-cluster-arn>",
      "TopicReplication": {
        "TopicsToReplicate": [".*"],
        "CopyTopicConfigurations": true,
        "CopyAccessControlListsForTopics": true,
        "DetectAndCopyNewTopics": true,
        "StartingPosition": {"Type": "LATEST"},
        "TopicNameConfiguration": {"Type": "PREFIXED"}
      },
      "ConsumerGroupReplication": {
        "ConsumerGroupsToReplicate": [".*"]
      },
      "TargetCompressionType": "NONE"
    }
  ]' \
  --log-delivery '{
    "ReplicatorLogDelivery": {
      "CloudWatchLogs": {
        "Enabled": true,
        "LogGroup": "/mskr/logs/<log-group-name>"
      },
      "S3": {
        "Enabled": true,
        "Bucket": "<s3-bucket-name>",
        "Prefix": "<optional-prefix>"
      },
      "Firehose": {
        "Enabled": true,
        "DeliveryStream": "<delivery-stream-name>"
      }
    }
  }'
```

Anda dapat mengaktifkan satu atau beberapa tujuan pengiriman log. Untuk mengaktifkan hanya CloudWatch Log Amazon, hilangkan `Firehose` bidang `S3` dan, atau setel `Enabled` nilainya. `false` Untuk informasi selengkapnya tentang pengiriman log, lihat[Log Replikator MSK](msk-replicator-logs.md).

**catatan**  
Saat pengiriman log diaktifkan, peran IAM Anda harus memiliki izin tambahan yang diperlukan untuk menulis ke tujuan log yang dikonfigurasi. Untuk izin yang diperlukan, lihat [Mengaktifkan logging dari AWS layanan](https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/AWS-vended-logs-permissions.html).

Untuk referensi API selengkapnya, lihat [CreateReplicator](https://docs.aws.amazon.com/msk/1.0/apireference-replicator/v1-replicators.html#CreateReplicator)di Referensi API MSK Amazon.

## Replikasi topik selektif
<a name="msk-replicator-cli-selective-topics"></a>

Gunakan pola regex di dalam `topicsToReplicate` dan `topicsToExclude` untuk mengontrol topik mana yang direplikasi. Contoh berikut mereplikasi topik yang dimulai dengan `prod-` dan mengecualikan topik yang dimulai dengan: `test-`

```
"topicReplication": {
  "topicsToReplicate": ["prod-.*"],
  "topicsToExclude": ["test-.*"],
  "detectAndCopyNewTopics": true
}
```

## Verifikasi status Replikator
<a name="msk-replicator-cli-verify-status"></a>

Setelah membuat Replicator, periksa statusnya menggunakan `describe-replicator` perintah:

```
aws kafka describe-replicator \
  --replicator-arn arn:aws:kafka:us-east-1:123456789012:replicator/my-replicator/xxx
```

Replikator berkembang melalui `CREATING` → `RUNNING` negara. Biarkan sekitar 30 menit agar Replicator mencapai `RUNNING` status. Jika transisi ke`FAILED`, lihat[Memecahkan masalah Amazon MSK Replicator](msk-replicator-troubleshooting.md).