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

# Bermigrasi dari cluster Apache Kafka non-MSK ke broker Amazon MSK Express
<a name="msk-replicator-migrate-external"></a>

Anda dapat menggunakan MSK Replicator untuk memigrasikan beban kerja Apache Kafka dari lingkungan yang dikelola sendiri ke kluster Amazon MSK Provisioned dengan broker Express. MSK Replicator mendukung migrasi data dari penerapan Kafka (Kafka versi 2.8.1 atau yang lebih baru) yang mengaktifkan otentikasi. SASL/SCRAM 

**catatan**  
SASL/SCRAM otentikasi diperlukan hanya untuk MSK Replicator untuk terhubung ke cluster Kafka yang dikelola sendiri. Aplikasi klien Anda dapat terus menggunakan mekanisme otentikasi yang ada.

**Prasyarat**  
Sebelum Anda mulai, pastikan Anda memiliki yang berikut:

1. Sumber Apache Kafka cluster yang menjalankan versi 2.8.1 atau yang lebih baru

1. SASL/SCRAM otentikasi diaktifkan pada cluster sumber

1. Enkripsi SSL dikonfigurasi pada cluster sumber

1. Konektivitas jaringan melalui AWS Site-to-Site VPN atau AWS Direct Connect

1. Subnet VPC dikonfigurasi untuk akses Secrets Manager

Untuk petunjuk mendetail, lihat [Siapkan prasyarat untuk MSK Replicator dengan cluster Apache Kafka yang dikelola sendiri](msk-replicator-external-prereqs.md).

**Langkah 1: Buat cluster Amazon MSK Express**  
Buat klaster MSK Provisioned dengan broker Express dengan otentikasi IAM diaktifkan. Minimal tiga broker di tiga AZ. Lihat [Siapkan cluster target](msk-replicator-prepare-clusters.md#msk-replicator-prepare-target).

**Langkah 2: Buat peran eksekusi IAM**  
Lampirkan kebijakan `AWSMSKReplicatorExecutionRole` terkelola dan konfigurasikan kebijakan kepercayaan untuk`kafka.amazonaws.com`. Tambahkan izin sebaris untuk AWS Secrets Manager (dan AWS KMS jika rahasia Anda CMK-encrypted) per. [Izin SER tambahan untuk SASL/SCRAM dan kunci yang dikelola pelanggan](msk-replicator-ser-additional-perms.md) Lihat [Siapkan prasyarat untuk MSK Replicator dengan cluster Apache Kafka yang dikelola sendiri](msk-replicator-external-prereqs.md).

**Langkah 3: Konfigurasikan SASL/SCRAM dan SSL pada cluster yang dikelola sendiri**  
Buat pengguna SCRAM khusus dengan izin ACL yang diperlukan. Konfigurasikan sertifikat SSL. Lihat [Siapkan prasyarat untuk MSK Replicator dengan cluster Apache Kafka yang dikelola sendiri](msk-replicator-external-prereqs.md).

**Langkah 4: Simpan kredensil di AWS Secrets Manager**  
Buat rahasia dengan`username`,`password`, dan pasangan `certificate` kunci-nilai. Lihat [Siapkan prasyarat untuk MSK Replicator dengan cluster Apache Kafka yang dikelola sendiri](msk-replicator-external-prereqs.md).

**Langkah 5: Buat Replicator**  
Gunakan `CreateReplicator` API dengan posisi `EARLIEST` awal, replikasi nama topik identik, dan `synchroniseConsumerGroupOffsets` atur ke`true`. Prinsipal IAM yang memanggil `CreateReplicator` harus memiliki izin pemanggil API yang dijelaskan dalam. [Izin IAM diperlukan untuk membuat Replikator MSK](msk-replicator-create-iam-perms.md) Jika Anda berencana untuk mengatur replikasi dua arah untuk kemampuan rollback (Langkah 6), atur `consumerGroupOffsetSyncMode` juga `ENHANCED` pada Replikator maju dan mundur. Biarkan sekitar 30 menit agar Replicator mencapai status RUNNING. Lihat [CreateReplicator Contoh API untuk cluster Kafka yang dikelola sendiri](msk-replicator-external-api-examples.md).

**Langkah 6: (Opsional) Mengatur replikasi dua arah**  
Buat Replicator terbalik dari cluster MSK Express kembali ke cluster yang dikelola sendiri untuk kemampuan rollback. Lihat [CreateReplicator Contoh API untuk cluster Kafka yang dikelola sendiri](msk-replicator-external-api-examples.md).

**Langkah 7: Pantau kemajuan replikasi**  
Pantau metrik berikut:
+ `MessageLag`(harus mencapai 0)
+ `ReplicationLatency`
+ `ConsumerGroupOffsetSyncFailure`(harus 0)
+ `ConsumerGroupCount`
+ `OffsetLag (MSK Cluster)` dan `OffsetLag (Non-MSK Cluster)`

Untuk informasi selengkapnya, lihat [Pantau replikasi](msk-replicator-monitor.md).

**Langkah 8: Migrasikan aplikasi**  
Ikuti langkah-langkah berikut untuk memigrasikan aplikasi Anda:

1. Hentikan produser menulis ke cluster yang dikelola sendiri

1. Konfigurasi ulang produsen ke cluster MSK Express dengan otentikasi IAM

1. Pantau `MessageLag` hingga mencapai 0

1. Hentikan konsumen di cluster yang dikelola sendiri

1. Konfigurasi ulang konsumen ke klaster MSK Express

**Langkah 9: (Opsional) Gulung kembali ke cluster yang dikelola sendiri**  
Jika replikasi dua arah dikonfigurasi, Anda dapat membalikkan langkah migrasi untuk memutar kembali ke klaster yang dikelola sendiri. Replikator terbalik (MSK Express → Eksternal) akan menjaga cluster yang dikelola sendiri tetap sinkron, sehingga konsumen dapat diarahkan kembali tanpa kehilangan data.