All Products
Search

This Product

    ApsaraMQ for Kafka:Migrasikan kluster Apache Kafka yang dikelola sendiri ke instance ApsaraMQ for Kafka

    Document Center

    ApsaraMQ for Kafka:Migrasikan kluster Apache Kafka yang dikelola sendiri ke instance ApsaraMQ for Kafka

    Last Updated:Jul 02, 2025

    Untuk mengurangi biaya, meningkatkan skalabilitas, dan memperbaiki keandalan kluster Apache Kafka yang dikelola sendiri, Anda dapat memigrasikannya ke instance ApsaraMQ for Kafka. ApsaraMQ for Kafka adalah layanan terkelola sepenuhnya yang memungkinkan Anda fokus pada pengembangan bisnis tanpa perlu melakukan penyebaran atau pemeliharaan.

    Catatan penggunaan

    • Setelah migrasi selesai, topik dan grup sumber di kluster Apache Kafka yang dikelola sendiri tidak akan dihapus. Sebagai gantinya, topik dan grup baru dengan konfigurasi yang sama akan dibuat di instance tujuan ApsaraMQ for Kafka.

    • Anda dapat memilih apakah akan memigrasikan data pesan dan informasi offset sesuai dengan kebutuhan bisnis Anda.

    Deskripsi solusi

    Saat memigrasikan kluster Apache Kafka yang dikelola sendiri ke instance ApsaraMQ for Kafka, gunakan konsumen asli untuk mengonsumsi semua pesan yang antri di kluster asli. Produsen dan konsumen berada dalam kluster yang sama. Anda dapat memigrasikan server dalam kluster satu per satu tanpa memengaruhi layanan lapisan atas. Untuk mengetahui manfaat migrasi kluster Apache Kafka yang dikelola sendiri ke instance ApsaraMQ for Kafka, lihat Manfaat.

    Gambar berikut mengilustrasikan cara memigrasikan kluster Apache Kafka yang dikelola sendiri ke instance ApsaraMQ for Kafka.

    ApsaraMQ for Kafka menyediakan solusi berikut:

    Item

    Migrasi cloud

    Impor metadata

    Migrasi dengan bantuan alat

    Metode migrasi

    Data dimigrasikan dengan membuat tugas migrasi di konsol ApsaraMQ for Kafka. Dalam kebanyakan kasus, kami sarankan Anda menggunakan metode ini untuk memigrasikan data.

    Data diekspor sebagai file JSON menggunakan alat kafka-migration-assessment.jar dan kemudian dimigrasikan dengan membuat tugas impor metadata di konsol ApsaraMQ for Kafka.

    Catatan

    Jika kluster Apache Kafka yang dikelola sendiri Anda tidak mendukung akses Internet, Anda dapat menggunakan metode ini untuk memigrasikan data.

    Data dimigrasikan menggunakan alat kafka-migration-assessment.jar atau MirrorMaker.

    Konten migrasi

    • Topik

    • Grup

    • Data pesan dan informasi offset

    • Daftar kontrol akses (ACL) yang dilampirkan pada topik

      Sebelum migrasi, Anda harus membuat pengguna Simple Authentication and Security Layer (SASL) di konsol ApsaraMQ for Kafka.

    • Topik

    • Grup

    • kafka-migration-assessment.jar

      • Topik

      • Grup

    • MirrorMaker

      • Data pesan dan informasi offset

    Proses migrasi

    1. Dapatkan titik akhir publik dari kluster Apache Kafka yang dikelola sendiri.

    2. Buat tugas migrasi cloud di konsol ApsaraMQ for Kafka.

    3. Mulai grup konsumen di instance ApsaraMQ for Kafka untuk mengonsumsi pesan yang dikirim ke instance tersebut.

    4. Mulai produsen di instance ApsaraMQ for Kafka, hentikan produsen di kluster Apache Kafka yang dikelola sendiri, dan gunakan grup konsumen asli untuk mengonsumsi pesan yang antri di kluster Apache Kafka yang dikelola sendiri.

    5. Setelah semua pesan di kluster Apache Kafka yang dikelola sendiri dikonsumsi oleh grup konsumen asli, hentikan grup konsumen dan kluster Apache Kafka yang dikelola sendiri.

    1. Gunakan alat migrasi untuk memigrasikan data di kluster Apache Kafka yang dikelola sendiri ke instance ApsaraMQ for Kafka.

    2. Mulai grup konsumen di instance ApsaraMQ for Kafka untuk mengonsumsi pesan yang dikirim ke instance tersebut.

    3. Mulai produsen di instance ApsaraMQ for Kafka, hentikan produsen di kluster Apache Kafka yang dikelola sendiri, dan gunakan grup konsumen asli untuk mengonsumsi pesan yang antri di kluster Apache Kafka yang dikelola sendiri.

    4. Setelah semua pesan di kluster Apache Kafka yang dikelola sendiri dikonsumsi oleh grup konsumen asli, hentikan grup konsumen dan kluster Apache Kafka yang dikelola sendiri.

    Referensi