Migrasikan topik dari kluster Kafka self-managed menggunakan tool migration - ApsaraMQ for Kafka

Topik ini menjelaskan cara menggunakan alat migrasi yang disediakan oleh ApsaraMQ for Kafka untuk memigrasikan topik dari kluster Kafka yang dikelola sendiri ke instance ApsaraMQ for Kafka.

Prasyarat

Pastikan operasi berikut telah selesai:

Java Development Kit (JDK) 8 telah diunduh dan diinstal. Untuk informasi lebih lanjut, lihat Unduhan Java.
Alat migrasi telah diunduh dan diinstal. Jika belum, klik kafka-migration-assessment.jar untuk mengunduh alat migrasi.
Sebuah instance ApsaraMQ for Kafka telah dibeli dan diterapkan.
- Untuk informasi tentang cara membeli dan menerapkan instance dalam virtual private cloud (VPC), lihat Beli dan Terapkan Instance yang Memungkinkan Akses dari VPC.
- Untuk informasi tentang cara membeli instance yang dapat diakses melalui Internet dan VPC serta menerapkannya, lihat Beli dan Terapkan Instance yang Memungkinkan Akses dari Internet dan VPC.

Prosedur

Buka CLI Anda.
Jalankan perintah cd untuk masuk ke direktori tempat alat migrasi disimpan.

Jalankan perintah berikut untuk memeriksa topik yang ingin dimigrasikan:

java -jar kafka-migration-assessment.jar TopicMigrationFromZk  \ 
--sourceZkConnect 192.168.XX.XX  \ 
--destAk <yourdestAccessKeyId>  \ 
--destSk <yourdestAccessKeySecret>  \ 
--destRegionId <yourdestRegionId>  \ 
--destInstanceId <yourdestInstanceId>

Parameter	Deskripsi
sourceZkConnect	Alamat IP kluster Apache Kafka sumber di ZooKeeper.
destAk	ID AccessKey akun Alibaba Cloud tempat instance ApsaraMQ for Kafka tujuan berada.
destSk	Rahasia AccessKey akun Alibaba Cloud tempat instance ApsaraMQ for Kafka tujuan berada.
destRegionId	ID wilayah tempat instance ApsaraMQ for Kafka tujuan diterapkan.
destInstanceId	ID instance ApsaraMQ for Kafka tujuan.

Periksa informasi yang dikembalikan. Informasi tersebut menjelaskan topik yang akan dimigrasikan.

13:40:08 INFO - Mulai memigrasikan topik:[test]
13:40:08 INFO - Total jumlah topik:1
13:40:08 INFO - Akan membuat topik:test, isCompactTopic:false, jumlah partisi:1

Jalankan perintah berikut untuk menyerahkan tugas migrasi:

java -jar kafka-migration-assessment.jar TopicMigrationFromZk  \ 
--sourceZkConnect 192.168.XX.XX  \ 
--destAk <yourdestAccessKeyId>  \ 
--destSk <yourdestAccessKeySecret>  \ 
--destRegionId <yourdestRegionId>  \ 
--destInstanceId <yourdestInstanceId>  \
--commit

Parameter	Deskripsi
commit	Menyerahkan tugas migrasi.

Setelah menyerahkan tugas migrasi, informasi berikut akan dikembalikan:

13:51:12 INFO - Mulai memigrasikan topik:[test]
13:51:12 INFO - Total jumlah topik:1
13:51:13 INFO - cmd=TopicMigrationFromZk, request=null, response={"code":200,"requestId":"7F76C7D7-AAB5-4E29-B49B-CD6F1E0F508B","success":true,"message":"operasi berhasil"}
13:51:13 INFO - Pembuatan Topik berhasil, topik=test, jumlah partisi=1, isCompactTopic=false

Untuk memeriksa apakah sebuah topik telah dimigrasikan, ikuti langkah-langkah berikut:
1. Masuk ke Konsol ApsaraMQ for Kafka.
2. Di bagian Resource Distribution pada halaman Overview, pilih wilayah tempat instance ApsaraMQ for Kafka yang ingin dikelola berada.
3. Di halaman Instances, klik nama instance yang ingin dikelola.
4. Di panel navigasi di sebelah kiri, klik Topics.
5. Di halaman Topics, periksa apakah topik tersebut ditampilkan.