Rebalance trafik topik - ApsaraMQ for Kafka

Saat meningkatkan spesifikasi trafik dari instance ApsaraMQ for Kafka, kluster terkait mungkin diperluas. Setelah perluasan kluster, Anda harus menyeimbangkan ulang trafik topik untuk mendistribusikan trafik secara merata di seluruh broker dalam kluster yang telah diperluas. Jika tidak, trafik topik asli tetap didistribusikan ke broker sebelum perluasan dan tunduk pada batas trafik maksimum yang dibeli sebelumnya. Topik baru tidak tunduk pada batas ini.

Prasyarat

Instance ApsaraMQ for Kafka berada dalam status Running (Pending Rebalancing).

Catatan

Untuk informasi tentang cara meningkatkan spesifikasi trafik instance ApsaraMQ for Kafka dan aturan pemicu perluasan kluster, lihat Upgrade Konfigurasi Instance.

Catatan penggunaan

Jika instance ApsaraMQ for Kafka berada dalam status Running (Pending Rebalancing), Anda dapat menggunakannya untuk mengirim dan menerima pesan. Namun, pembuatan sumber daya seperti topik dan grup tidak diizinkan hingga trafik topik diseimbangkan kembali. Anda juga dapat memilih untuk tidak melakukan penyeimbangan ulang trafik topik.

Metode penyeimbangan ulang trafik

Metode Penyeimbangan Ulang Trafik	Mekanisme Kerja	Dampak	Skenario	Durasi
Add Partitions to All Topics	Setelah perluasan kluster, sistem menambahkan partisi ke broker baru untuk semua topik pada broker asli.	Pesan baru dalam partisi tidak berurutan. Jumlah partisi berubah. Jika klien Anda tidak dapat mendeteksi partisi baru secara otomatis, Anda mungkin perlu me-restart klien atau memodifikasi kode klien. Hal ini relevan dalam skenario ETL atau saat mengirim/mengonsumsi pesan dari partisi tertentu.	Urutan partisi tidak diperlukan. Partisi tempat pesan dikirim tidak ditentukan. Mode konsumsi yang dipilih adalah langganan.	Dalam hitungan detik.
Migrate Data from Partitions of All Topics (Recommended)	Penyimpanan lokal: Alat kafka-reassign-partitions digunakan untuk memigrasi data topik di antara partisi. Penyimpanan cloud: Pemetaan dimodifikasi, tetapi data topik tidak dimigrasikan di antara partisi. Catatan Anda hanya dapat menentukan penyimpanan lokal sebagai mesin penyimpanan saat membuat topik untuk instance Edisi Profesional.	Penyimpanan lokal: Trafik internal sementara dihasilkan. Penyimpanan cloud: Tidak ada trafik internal sementara yang dihasilkan.	Semua skenario di mana kluster diperluas.	Penyimpanan lokal: Dalam hitungan menit atau jam. Durasi aktual tergantung pada jumlah data yang ingin dimigrasikan. Jika volume data besar, migrasi mungkin memerlukan beberapa jam atau lebih lama. Kami merekomendasikan agar Anda memigrasikan data selama jam-jam sepi. Penyimpanan cloud: Dalam hitungan detik. Sebuah topik membutuhkan waktu sekitar 30 detik untuk dimigrasikan.
Do Not Rebalance (Not Recommended)	Tidak diperlukan operasi. Topik asli tetap didistribusikan pada broker kluster sebelum perluasan, dan topik baru didistribusikan secara merata di semua broker setelah perluasan.	Topik asli tunduk pada spesifikasi trafik yang dibeli sebelum perluasan. Jika volume trafik topik asli besar, trafik mungkin tidak seimbang di antara broker.	Volume trafik topik asli kecil dan tidak bertambah banyak setelah kluster diperluas. Topik dibuat setelah kluster diperluas. Sebagian besar trafik diarahkan ke topik baru.	Konfigurasi langsung berlaku.

Prosedur

Catatan

Penyeimbangan ulang topik dipicu secara otomatis pada instance ApsaraMQ for Kafka tanpa server. Anda tidak perlu melakukan operasi di konsol ApsaraMQ for Kafka.

Masuk ke konsol ApsaraMQ for Kafka. Di bagian Resource Distribution halaman Overview, pilih wilayah tempat instance ApsaraMQ for Kafka yang ingin Anda kelola berada.
Di halaman Instances, klik nama instance yang ingin Anda kelola.
Di halaman Instance Details, klik Rebalance Topic Traffic di pojok kanan atas bagian Overview.
Di panel Rebalance Topic Traffic for Instance, konfigurasikan parameter Traffic Rebalancing Method. Untuk informasi tentang metode penyeimbangan ulang trafik yang didukung, lihat Metode Penyeimbangan Ulang Trafik.
Setelah memilih metode penyeimbangan ulang trafik, semua topik pada instance memasuki status Pending Rebalancing. Anda dapat memeriksa status topik di kolom Status pada halaman Topics.

Hasil eksekusi

Setelah trafik topik diseimbangkan kembali, topik memasuki status Running. Anda dapat memeriksa status topik di kolom Status pada halaman Topics.