:Migrasikan grup dari kluster Kafka yang dikelola sendiri ke ApsaraMQ for Kafka

Prosedur

1. Buka CLI Anda.

2. Jalankan perintah cd untuk masuk ke direktori tempat alat migrasi disimpan.

3. Buat file konfigurasi bernama kafka.properties.

   Sistem mendefinisikan hubungan langganan dan mendapatkan offset konsumen dari grup konsumen asli berdasarkan pengaturan yang dikonfigurasikan di file kafka.properties. File konfigurasi berisi informasi berikut:

   ## Titik akhir. 
   bootstrap.servers=localhost:9092
   
   ## ID grup. Grup Pastikan grup tidak berisi informasi offset konsumen. Jika grup berisi informasi offset konsumen, grup mungkin tidak mengonsumsi pesan dari pesan pertama yang perlu dikonsumsi.Grup 
   group.id=XXX
   
   ## Jika Anda tidak memerlukan otorisasi sertifikat, Anda tidak perlu mengonfigurasi parameter berikut. 
   
   ## Mekanisme Simple Authentication and Security Layer (SASL). 
   #sasl.mechanism=PLAIN
   
   ## Protokol akses. 
   #security.protocol=SASL_SSL
   
   ## Jalur sertifikat root Secure Sockets Layer (SSL). 
   #ssl.truststore.location=/Users/***/Documents/code/aliware-kafka-demos/main/resources/kafka.client.truststore.jks
   
   ## Kata sandi sertifikat root SSL. 
   #ssl.truststore.password=***
   
   ## Jalur file konfigurasi yang ingin Anda gunakan untuk SASL. 
   #java.security.auth.login.config=/Users/***/kafka-java-demo/vpc-ssl/src/main/resources/kafka_client_jaas.conf

4. Jalankan perintah berikut untuk memeriksa informasi tentang grup yang ingin dimigrasikan:Grup

   java -jar kafka-migration-assessment.jar ConsumerGroupMigrationFromTopic  \ 
   --propertiesPath /usr/local/kafka_2.12-2.4.0/config/kafka.properties  \ 
   --destAk <yourAccessKeyId>  \ 
   --destSk <yourAccessKeySecret>  \ 
   --destRegionId <yourRegionId>  \ 
   --destInstanceId <yourInstanceId>

   Parameter	Deskripsi
   propertiesPath	Jalur file konfigurasi kafka.properties.
   destAk	ID AccessKey dari akun Alibaba Cloud tempat instance tujuan ApsaraMQ for Kafka berada.
   destSk	Rahasia AccessKey dari akun Alibaba Cloud tempat instance tujuan ApsaraMQ for Kafka berada.
   destRegionId	ID wilayah tempat instance tujuan ApsaraMQ for Kafka diterapkan.
   destInstanceId	ID instance tujuan ApsaraMQ for Kafka.

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

   15:29:45 INFO - Akan membuat grup konsumen:[XXX, test-consumer-group]

5. Jalankan perintah berikut untuk menyerahkan tugas migrasi topik:Grup

   java -jar kafka-migration-assessment.jar ConsumerGroupMigrationFromTopic  \ 
   --propertiesPath /usr/local/kafka_2.12-2.4.0/config/kafka.properties  \ 
   --destAk <yourAccessKeyId>  \ 
   --destSk <yourAccessKeySecret>  \ 
   --destRegionId <yourRegionId>  \ 
   --destInstanceId <yourInstanceId>  \
   --commit

   Parameter	Deskripsi
   commit	Menyerahkan tugas migrasi.

   Setelah Anda menyerahkan tugas migrasi, informasi berikut akan dikembalikan:

   15:35:51 INFO - cmd=ConsumerGroupMigrationFromTopic, request=null, response={"code":200,"requestId":"C9797848-FD4C-411F-966D-0D4AB5D12F55","success":true,"message":"operasi berhasil"}
   15:35:51 INFO - ConsumerCreate berhasil, grup konsumen=XXX
   15:35:57 INFO - cmd=ConsumerGroupMigrationFromTopic, request=null, response={"code":200,"requestId":"3BCFDBF2-3CD9-4D48-92C3-385C8DBB9709","success":true,"message":"operasi berhasil"}
   15:35:57 INFO - ConsumerCreate berhasil, grup konsumen=test-consumer-group

   Setelah Anda menyerahkan tugas untuk memigrasikan topik ke instance ApsaraMQ for Kafka, Anda dapat masuk ke Konsol ApsaraMQ for Kafka dan melihat informasi tentang tugas migrasi di halaman Migration to Cloud.