Mengalihkan Antrian Pesan
Panduan ini menjelaskan cara mengganti antrian pesan (MQ) pada deployment Milvus yang sudah ada antara Woodpecker dan antrian pesan lainnya, secara online dan tanpa downtime.
Fitur ini masih dalam tahap pengembangan dan dapat berubah sewaktu-waktu. Silakan hubungi dukungan Milvus jika Anda ingin mencobanya atau memiliki pertanyaan.
Persyaratan
- Fitur Penggantian MQ tersedia di Milvus 3.0 dan versi yang lebih baru. Perbarui instance Milvus Anda ke Milvus 3.0 atau versi yang lebih baru sebelum menggunakannya — fitur ini tidak tersedia pada versi sebelumnya.
- Instan tersebut berjalan dengan baik.
Cakupan
Panduan ini hanya membahas peralihan antara Woodpecker dan antrian pesan lainnya. Peralihan langsung antara Pulsar dan Kafka berada di luar cakupan panduan ini.
- Beralih antara RocksMQ dan Woodpecker — Milvus Standalone (Docker Compose)
- Beralih antara Pulsar dan Woodpecker — kluster Milvus (Helm / Milvus Operator)
- Beralih antara Kafka dan Woodpecker — Kluster Milvus (Helm / Milvus Operator)
Alur kerja umum
- Pastikan instance Milvus berjalan dengan baik.
- Konfirmasikan jenis MQ sumber dan jenis MQ tujuan.
- Terapkan pengaturan akses MQ tujuan ke konfigurasi Milvus tanpa mengubah nilai `
mqType`. - Picu peralihan dengan memanggil API WAL alter di MixCoord.
- Pantau log untuk memastikan peralihan telah selesai.
Sebelum melakukan peralihan, pastikan MQ tujuan tidak mengandung topik dengan nama yang sama dengan yang digunakan oleh instance Milvus saat ini. Hal ini sangat penting jika MQ tujuan pernah digunakan oleh instance Milvus lain, karena nama topik yang bertabrakan dapat menyebabkan perilaku yang tidak terduga.
Matriks dukungan
| MQ Sumber | MQ Tujuan | Penerapan | Status |
|---|---|---|---|
| RocksMQ | Woodpecker (lokal/MinIO) | Standalone (Docker Compose) | Didukung |
| Woodpecker (lokal/MinIO) | RocksMQ | Standalone (Docker Compose) | Didukung |
| Pulsar (bawaan/eksternal) | Woodpecker (MinIO) | Cluster (Helm / Operator) | Didukung |
| Woodpecker (MinIO) | Pulsar (eksternal) | Cluster (Helm / Operator) | Didukung |
| Kafka (bawaan/eksternal) | Woodpecker (MinIO) | Cluster (Helm / Operator) | Didukung |
| Woodpecker (MinIO) | Kafka (eksternal) | Cluster (Helm / Operator) | Didukung |
| Woodpecker MinIO | Woodpecker lokal (atau sebaliknya) | apa saja | Tidak didukung |
Hindari berpindah-pindah jenis MQ berulang kali. Jika Anda memang perlu berpindah, pastikan untuk membersihkan data terkait sebelum setiap perpindahan — data sisa dapat menyebabkan perilaku yang tidak terduga.
