ApsaraMQ for Kafka menyediakan layanan migrasi cloud yang sepenuhnya terkelola. Anda dapat menggunakan layanan ini untuk menyinkronkan data dari cluster yang dikelola sendiri atau instans lintas cloud ke instans ApsaraMQ for Kafka. Setelah migrasi, metadata—seperti konfigurasi topik dan kelompok—serta data pesan dari kluster sumber disinkronkan ke instans tujuan. Metadata pada instans tujuan tetap konsisten dengan kluster sumber dan terus diperbarui secara berkelanjutan.
Prasyarat
Anda telah membeli dan men-deploy instans ApsaraMQ for Kafka yang memenuhi kondisi berikut:
Item | Deskripsi |
Status | Running |
Versi | Versi utama adalah 2.2.0 atau 2.6.2, dan versi minor adalah yang terbaru. |
Anda dapat melihat status dan versi instans di bagian Enter Basic Information pada halaman Instances di Konsol ApsaraMQ for Kafka.
Batasan
ApsaraMQ for Kafka menerapkan batasan berikut pada tugas migrasi cloud:
Item | Batasan |
Jumlah | Satu instans mendukung maksimal 20 tugas migrasi. Tugas migrasi cloud dan tugas konektor berbagi sumber daya pada satu instans. |
Jenis spesifikasi |
|
Versi instans sumber | Versi open source harus 1.0.0 atau lebih baru. |
Penagihan
Komponen migrasi cloud dari ApsaraMQ for Kafka berada dalam pratinjau publik dan bersifat independen dari instans ApsaraMQ for Kafka. Oleh karena itu, tidak ada biaya yang dikenakan untuk layanan ApsaraMQ for Kafka. Alibaba Cloud tidak menyediakan Service-Level Agreement (SLA) untuk migrasi ini. Untuk informasi mengenai SLA dan penagihan produk lain yang digunakan oleh migrasi cloud, lihat dokumentasi produk tersebut.
Persyaratan lingkungan
Untuk menggunakan fitur migrasi cloud guna menyinkronkan data dari instans yang dikelola sendiri yang terhubung melalui Internet ke instans ApsaraMQ for Kafka, atau menyinkronkan data lintas wilayah dari instans ApsaraMQ for Kafka di VPC ke instans ApsaraMQ for Kafka di VPC lain, Anda harus mengaktifkan akses Internet untuk instans tujuan dan melakukan sinkronisasi data melalui Internet. Untuk informasi selengkapnya, lihat (Opsional) Aktifkan akses Internet.
Untuk menyinkronkan data dari instans di satu VPC ke instans ApsaraMQ for Kafka di VPC lain, VPC secara otomatis terhubung di wilayah China (Hangzhou) dan China (Chengdu). Di wilayah lain, Anda harus menghubungkan VPC secara manual. Untuk informasi selengkapnya, lihat Hubungkan VPC lintas wilayah.
Aktifkan akses jaringan publik (opsional)
Aktifkan akses jaringan publik jika Anda ingin menggunakan fitur migrasi cloud untuk mengakses layanan Alibaba Cloud lain atau titik akhir jaringan publik lintas wilayah.
Buat NAT Gateway untuk VPC tempat instans ApsaraMQ for Kafka dideploy.
Untuk informasi selengkapnya, lihat Internet NAT Gateway.
Kaitkan alamat IP elastis (EIP) dengan NAT Gateway.
Untuk informasi selengkapnya, lihat Kaitkan EIP dengan sumber daya cloud.
Buat entri SNAT untuk vSwitch yang digunakan oleh instans ApsaraMQ for Kafka di VPC.
Untuk informasi selengkapnya, lihat Buat dan kelola entri SNAT.
Buat dan deploy tugas migrasi cloud
Masuk ke Konsol ApsaraMQ for Kafka. Di bagian Resource Distribution pada halaman Overview, pilih wilayah tempat instans ApsaraMQ for Kafka yang ingin Anda kelola berada.
Di panel navigasi sebelah kiri, klik Migration. Pada halaman yang muncul, klik tab Cloud Migration.
Di tab Cloud Migration, klik Create Task.
Di panel Create Cloud Migration Task, konfigurasikan parameter berikut.
Di tab Configure Basic Information, atur Task Name dan Destination Instance, lalu klik Next.
Di tab Configure Source Service, konfigurasikan parameter layanan sumber, lalu klik Next.
Jika Anda mengatur Source Instance Type ke VPC (Interconnection Between Self-managed Instance and VPC), konfigurasikan parameter berikut.
Parameter
Deskripsi
Contoh
Source Region
Pilih wilayah instans sumber.
China (Hangzhou)
Endpoint
Titik akhir instans sumber.
192.168.XX.XX:9092
VPC ID
ID VPC tempat instans sumber dideploy. Parameter ini diisi otomatis dengan VPC instans sumber. Anda tidak perlu mengaturnya.
vpc-test-c****
vSwitch ID
ID vSwitch untuk instans sumber.
vsw-bp1gbjqsf53og****
Security Group
Pilih grup keamanan instans sumber.
alikafka_pre-cn-7mz2****
Security Protocol
Pilih protokol keamanan instans sumber.
PLAINTEXT
SASL_PLAINTEXT
SASL Username: Masukkan username SASL.
SASL Password: Masukkan password SASL.
Sasl_Mechanism: Mekanisme autentikasi SASL. Nilai yang valid adalah PLAIN, SCRAM-SHA-256, dan SCRAM-SHA-512.
SASL_SSL
SASL Username: Masukkan username SASL.
SASL Password: Masukkan password SASL.
Sasl_Mechanism: Mekanisme autentikasi SASL. Nilai yang valid adalah PLAIN, SCRAM-SHA-256, dan SCRAM-SHA-512.
SSL Truststore File: Unggah file sertifikat.
SSL Truststore Password: Masukkan password untuk sertifikat.
SSL Endpoint Identification Algorithm: Properti SSL yang menentukan algoritma untuk memverifikasi sertifikat server. Dalam komunikasi SSL, Anda dapat menggunakan parameter ini untuk mengautentikasi identitas server dan mencegah serangan man-in-the-middle. Anda dapat memasukkan https, http, atau string kosong.
PLAINTEXT
Number of Tasks
Pilih jumlah tugas untuk sinkronisasi data. Nilai yang valid:
1
6
12
12
Synchronize SASL Users
Tentukan apakah akan menyinkronkan pengguna SASL selama migrasi data. Parameter ini muncul setelah Anda mengklik Configure Runtime Environment. Nilai default adalah Yes.
Yes
Synchronize Topic ACLs
Tentukan apakah akan menyinkronkan ACL topik selama migrasi data. Parameter ini muncul setelah Anda mengklik Configure Runtime Environment. Nilai default adalah Yes.
Yes: Menyinkronkan informasi ACL topik dari instans sumber ke instans tujuan. Jika instans sumber dikelola sendiri, Anda harus membuat pengguna SASL secara manual di instans tujuan sebelum dapat menyinkronkan ACL topik.
No: Tidak menyinkronkan informasi ACL topik dari instans sumber ke instans tujuan.
Yes
Synchronize Consumer Groups
Tentukan apakah akan menyinkronkan dan membuat kelompok konsumen dari instans sumber di instans tujuan. Parameter ini muncul setelah Anda mengklik Configure Runtime Environment. Nilai default adalah Yes.
Yes
Synchronize Consumer Offsets
Tentukan apakah akan menyinkronkan dan membuat offset konsumen dari instans sumber di instans tujuan. Parameter ini muncul setelah Anda mengklik Configure Runtime Environment dan mengatur Synchronize Consumer Groups ke Yes. Nilai default adalah Yes.
Yes
Topic
Topik di instans sumber yang akan disinkronkan ke instans tujuan. Jika Anda biarkan kosong, semua topik akan disinkronkan. Parameter ini muncul setelah Anda mengklik Configure Runtime Environment.
test-topic
Create Topics to Use Local Storage
Topik non-compact yang akan dimigrasikan ke instans tujuan. Jika Anda ingin topik ini menggunakan mesin Local, masukkan nama-namanya di sini. Jika Anda biarkan kosong, topik akan dibuat menggunakan mesin Cloud. Parameter ini muncul setelah Anda mengklik Configure Runtime Environment.
test-topic
Jika Anda mengatur Source Instance Type ke Public Network (IDC or Cross-cloud Instance), konfigurasikan parameter berikut.
Parameter
Deskripsi
Contoh
Endpoint
Titik akhir instans sumber.
192.168.XX.XX:9092
Security Group
Pilih grup keamanan instans sumber.
alikafka_pre-cn-7mz2****
Security Protocol
Pilih protokol keamanan instans sumber.
PLAINTEXT
SASL_PLAINTEXT
SASL Username: Masukkan username SASL.
SASL Password: Masukkan password SASL.
Sasl_Mechanism: Mekanisme autentikasi SASL. Nilai yang valid adalah PLAIN, SCRAM-SHA-256, dan SCRAM-SHA-512.
SASL_SSL
SASL Username: Masukkan username SASL.
SASL Password: Masukkan password SASL.
Sasl_Mechanism: Mekanisme autentikasi SASL. Nilai yang valid adalah PLAIN, SCRAM-SHA-256, dan SCRAM-SHA-512.
SSL Truststore File: Unggah file sertifikat.
SSL Truststore Password: Masukkan password untuk sertifikat.
SSL Endpoint Identification Algorithm: Properti SSL yang menentukan algoritma untuk memverifikasi sertifikat server. Dalam komunikasi SSL, Anda dapat menggunakan parameter ini untuk mengautentikasi identitas server dan mencegah serangan man-in-the-middle. Anda dapat memasukkan https, http, atau string kosong.
PLAINTEXT
Number of Tasks
Pilih jumlah tugas untuk sinkronisasi data. Nilai yang valid:
1
6
12
12
Synchronize SASL Users
Tentukan apakah akan menyinkronkan informasi pengguna SASL dari instans ke instans tujuan. Parameter ini muncul setelah Anda mengklik Configure Runtime Environment. Nilai default adalah Yes.
Yes
Synchronize Topic ACLs
Tentukan apakah akan menyinkronkan ACL topik selama migrasi data. Parameter ini muncul setelah Anda mengklik Configure Runtime Environment. Nilai default adalah Yes.
Yes: Menyinkronkan informasi ACL topik dari instans sumber ke instans tujuan. Jika instans sumber dikelola sendiri, Anda harus membuat pengguna SASL secara manual di instans tujuan sebelum dapat menyinkronkan ACL topik.
No: Tidak menyinkronkan informasi ACL topik dari instans sumber ke instans tujuan.
Yes
Synchronize Consumer Groups
Tentukan apakah akan menyinkronkan dan membuat kelompok konsumen dari instans sumber di instans tujuan. Parameter ini muncul setelah Anda mengklik Configure Runtime Environment. Nilai default adalah Yes.
Yes
Synchronize Consumer Offsets
Tentukan apakah akan menyinkronkan dan membuat offset konsumen dari instans sumber di instans tujuan. Parameter ini muncul setelah Anda mengklik Configure Runtime Environment dan mengatur Synchronize Consumer Groups ke Yes. Nilai default adalah Yes.
Yes
Topic
Topik di instans sumber yang akan disinkronkan ke instans tujuan. Jika Anda biarkan kosong, semua topik akan disinkronkan. Parameter ini muncul setelah Anda mengklik Configure Runtime Environment.
test-topic
Create Topics to Use Local Storage
Topik non-compact yang akan dimigrasikan ke instans tujuan. Jika Anda ingin topik ini menggunakan mesin Local, masukkan nama-namanya di sini. Jika Anda biarkan kosong, topik akan dibuat menggunakan mesin Cloud. Parameter ini muncul setelah Anda mengklik Configure Runtime Environment.
test-topic
Di tab Configure Destination Service, klik Create.
Setelah tugas dibuat, di halaman Migration, pilih instans tujuan dari daftar drop-down Instance. Temukan tugas tersebut dan klik Deploy di kolom Actions.
Di halaman Migration, jika Status tugas berubah menjadi Running, berarti tugas berhasil dideploy.
Operasi lainnya
Di halaman Migration, pilih instans tempat tugas tersebut berada dari daftar drop-down Instance. Temukan tugas yang dituju di daftar tugas dan lakukan operasi lain di kolom Actions.
Lihat detail tugas: Klik Details. Di halaman detail tugas, Anda dapat melihat Basic Information, Source Service, Destination Service, dan Runtime Environment dari tugas migrasi cloud.
Lihat progres sinkronisasi: Klik Synchronization Progress, pilih topik yang ingin Anda lihat progresnya, lalu klik OK.
Ubah konfigurasi tugas: Klik Modify Configuration. Di panel yang muncul, ubah parameter tugas sesuai kebutuhan.
Reset offset konsumen: Pilih . Atur topik dan metode reset, lalu klik OK. Untuk informasi selengkapnya tentang cara mereset offset konsumen, lihat Reset consumer offsets.
Jeda atau aktifkan tugas: Pilih atau . Di kotak dialog Prompt, klik Confirm.
Hapus tugas: Pilih . Di kotak dialog Prompt, klik Confirm.