ApsaraMQ for Kafka:Migrasi ke cloud

Proses migrasi

Catatan penggunaan

• Jika Anda ingin menggunakan instans ApsaraMQ for Kafka non-serverless sebagai instans tujuan saat membuat tugas migrasi, pastikan Anda memilih instans yang berada pada Professional Edition (High Write) atau Professional Edition (High Read) dengan versi utama 2.2.0 atau lebih baru.

• Jika Anda ingin memigrasikan metadata dan data pesan dari kluster Apache Kafka yang dikelola sendiri yang di-deploy di Alibaba Cloud, kami menyarankan Anda membeli instans ApsaraMQ for Kafka di wilayah yang sama dengan kluster tersebut, deploy-nya dalam virtual private cloud (VPC) yang sama, lalu lakukan migrasi metadata dan data pesan melalui VPC tersebut.

• Dalam topik ini, metadata dan data pesan dari kluster Apache Kafka yang dikelola sendiri dimigrasikan ke instans ApsaraMQ for Kafka yang Internet- and VPC-connected.

Langkah 1: Evaluasi spesifikasi

ApsaraMQ for Kafka menyediakan fitur evaluasi spesifikasi yang menilai dan merekomendasikan spesifikasi instans ApsaraMQ for Kafka yang dibutuhkan untuk tugas migrasi berdasarkan informasi kluster Apache Kafka yang dikelola sendiri, seperti traffic kluster, kapasitas disk, dan tipe disk. Untuk informasi selengkapnya, lihat Evaluasi spesifikasi.

Langkah 2: Beli instans

Beli instans ApsaraMQ for Kafka berdasarkan spesifikasi instans yang telah dievaluasi dan lakukan deployment-nya. Untuk informasi selengkapnya, lihat Beli dan deploy instans yang terhubung ke Internet dan VPC.

Langkah 3: Buat tugas migrasi

1. Login ke Konsol ApsaraMQ for Kafka. Di bagian Resource Distribution pada halaman Overview, pilih wilayah tempat instans ApsaraMQ for Kafka yang ingin Anda kelola berada.

2. Di panel navigasi sebelah kiri, klik Migration. Pada halaman yang muncul, klik tab Cloud Migration.

3. Di tab Cloud Migration, klik Create Task.

4. Pada wizard Create Cloud Migration Task, konfigurasikan parameter-parameter berikut.

   1. Pada langkah Configure Basic Information, atur parameter Task Name dan Destination Instance, lalu klik Next.

   2. Pada langkah Configure Source Service, atur parameter Source Instance Type menjadi Public Network (IDC or Cross-cloud Instance) dan konfigurasikan parameter lainnya. Lalu, klik Next.

• PLAINTEXT

• SASL_PLAINTEXT

  • SASL Username: Masukkan username SASL.

  • SASL Password: Masukkan password SASL.

  • Sasl_Mechanism: Pilih mekanisme otentikasi SASL. Nilai yang valid: PLAIN, SCRAM-SHA-256, dan SCRAM-SHA-512.

• SASL_SSL

  • SASL Username: Masukkan username SASL.

  • SASL Password: Masukkan password SASL.

  • Sasl_Mechanism: Pilih mekanisme otentikasi SASL. Nilai yang valid: PLAIN, SCRAM-SHA-256, dan SCRAM-SHA-512.

  • SSL Truststore File: Unggah file sertifikat.

  • SSL Truststore Password: Masukkan password sertifikat.

  • SSL Endpoint Identification Algorithm: Tentukan algoritma yang digunakan untuk memverifikasi sertifikat server. Jika Anda menggunakan protokol SSL untuk komunikasi, Anda dapat mengonfigurasi parameter ini untuk memverifikasi identitas server guna mencegah serangan man-in-the-middle. Anda dapat memasukkan https, http, atau string kosong di bidang ini.

| PLAINTEXT Number of Tasks| Jumlah tugas untuk sinkronisasi data. Nilai yang valid:

• 1

• 6

• 12

| 12 Synchronize SASL Users| Menentukan apakah akan menyinkronkan data konfigurasi pengguna SASL dari kluster Apache Kafka yang dikelola sendiri ke instans ApsaraMQ for Kafka. Parameter ini hanya ditampilkan setelah Anda mengklik Configure Runtime Environment. Nilai default: No.| Yes Synchronize Topic ACLs| Menentukan apakah akan menyinkronkan data konfigurasi daftar kontrol akses (ACL) yang dilampirkan pada topik di kluster Apache Kafka yang dikelola sendiri ke instans ApsaraMQ for Kafka. Parameter ini hanya ditampilkan setelah Anda mengklik Configure Runtime Environment. Nilai default: No.

• Yes: Data konfigurasi ACL yang dilampirkan pada topik di kluster Apache Kafka yang dikelola sendiri disinkronkan ke instans ApsaraMQ for Kafka. Sebelum menyinkronkan data konfigurasi ACL ke instans tersebut, Anda harus membuat pengguna SASL pada instans ApsaraMQ for Kafka.

• No: Data konfigurasi ACL yang dilampirkan pada topik di kluster Apache Kafka yang dikelola sendiri tidak disinkronkan ke instans ApsaraMQ for Kafka.

| Yes Synchronize Consumer Groups| Menentukan apakah akan menyinkronkan kelompok konsumen dari kluster Apache Kafka yang dikelola sendiri ke instans ApsaraMQ for Kafka. Parameter ini hanya ditampilkan setelah Anda mengklik Configure Runtime Environment. Nilai default: No.| Yes Synchronize Consumer Offsets| Menentukan apakah akan menyinkronkan offset konsumen dari kluster Apache Kafka yang dikelola sendiri ke instans ApsaraMQ for Kafka. Parameter ini hanya ditampilkan setelah Anda mengklik Configure Runtime Environment dan mengatur parameter Synchronize Consumer Groups menjadi Yes. Nilai default: No.| Yes Topic| Topik yang ingin Anda sinkronkan ke instans ApsaraMQ for Kafka. Jika Anda tidak mengonfigurasi parameter ini, semua topik di kluster Apache Kafka yang dikelola sendiri akan disinkronkan. Parameter ini hanya ditampilkan setelah Anda mengklik Configure Runtime Environment.| test-topic Create Topics to Use Local Storage| Topik non-log-compacted yang ingin Anda sinkronkan ke instans ApsaraMQ for Kafka. Jika Anda ingin topik yang dibuat menggunakan penyimpanan lokal, Anda harus mengonfigurasi parameter ini. Jika tidak dikonfigurasi, topik yang dibuat akan menggunakan penyimpanan cloud. Parameter ini hanya ditampilkan setelah Anda mengklik Configure Runtime Environment.| test-topic

1. Pada langkah Configure Destination Service, klik Create.

1. Di tab Cloud Migration pada halaman Migration, pilih instans tujuan dari daftar drop-down Instance, temukan tugas migrasi yang telah dibuat, lalu klik Deploy di kolom Actions.

Jika tugas migrasi telah dibuat, Anda akan melihat bahwa kolom Status yang sesuai dengan tugas tersebut berubah menjadi Running di tab Cloud Migration pada halaman Migration.

Langkah 4: Lihat progres

1. Di halaman Migration, klik tab Cloud Migration.

2. Temukan tugas yang ingin Anda kelola dan klik Synchronization Progress di kolom Actions.

3. Di daftar drop-down Select a topic pada panel Synchronization Progress, lihat topik-topik yang telah disinkronkan.

4. Pilih topik yang ingin Anda lihat dari daftar drop-down Select a topic untuk memeriksa status sinkronisasi data pada setiap partisi topik tersebut.

Langkah selanjutnya

1. Aktifkan kelompok konsumen baru untuk instans ApsaraMQ for Kafka agar dapat mengonsumsi pesan di instans tersebut.

2. Aktifkan produsen baru untuk instans ApsaraMQ for Kafka, matikan produsen asli, dan biarkan kelompok konsumen asli terus mengonsumsi pesan di kluster Apache Kafka yang dikelola sendiri.

3. Setelah semua pesan di kluster Apache Kafka yang dikelola sendiri dikonsumsi oleh kelompok konsumen asli, matikan kelompok konsumen asli dan kluster Apache Kafka yang dikelola sendiri tersebut.