Cambio de cola de mensajes
Esta guía describe cómo cambiar la cola de mensajes (MQ) de una implementación existente de Milvus de Woodpecker a otra cola de mensajes, en línea y sin tiempo de inactividad.
Esta función está pendiente de lanzamiento y está sujeta a cambios. Ponte en contacto con el servicio de asistencia de Milvus si deseas probarla o tienes alguna pregunta.
Requisitos previos
- La función «Cambiar cola de mensajes» está disponible en Milvus 3.0 y versiones posteriores. Actualiza tu instancia de Milvus a la versión 3.0 o posterior antes de utilizarla, ya que la función no está disponible en versiones anteriores.
- La instancia funciona correctamente.
Ámbito
Esta guía solo trata el cambio entre Woodpecker y otra cola de mensajes. El cambio directo entre Pulsar y Kafka queda fuera del alcance de esta guía.
- Cambio entre RocksMQ y Woodpecker — Milvus independiente (Docker Compose)
- Cambio entre Pulsar y Woodpecker — Clúster de Milvus (Helm / Milvus Operator)
- Cambio entre Kafka y Woodpecker — Clúster de Milvus (Helm / Milvus Operator)
Flujo de trabajo general
- Asegúrate de que la instancia de Milvus se está ejecutando correctamente.
- Confirma el tipo de MQ de origen y el tipo de MQ de destino.
- Aplica los ajustes de acceso de la cola de mensajes de destino a la configuración de Milvus sin modificar el valor de «
mqType». - Activa el cambio llamando a la API «WAL alter» en MixCoord.
- Supervisa los registros para confirmar que el cambio se ha completado.
Antes de realizar la conmutación, asegúrate de que la MQ de destino no contenga temas con los mismos nombres que los utilizados por la instancia actual de Milvus. Esto es especialmente importante si la MQ de destino ha sido utilizada por otra instancia de Milvus, ya que los nombres de temas conflictivos pueden provocar un comportamiento inesperado.
Matriz de compatibilidad
| MQ de origen | MQ de destino | Implementación | Estado |
|---|---|---|---|
| RocksMQ | Woodpecker (local/MinIO) | Autónomo (Docker Compose) | Compatible |
| Woodpecker (local/MinIO) | RocksMQ | Autónomo (Docker Compose) | Compatible |
| Pulsar (integrado/externo) | Woodpecker (MinIO) | Clúster (Helm / Operador) | Compatible |
| Woodpecker (MinIO) | Pulsar (externo) | Clúster (Helm / Operator) | Compatible |
| Kafka (integrado/externo) | Woodpecker (MinIO) | Clúster (Helm / Operador) | Compatible |
| Woodpecker (MinIO) | Kafka (externo) | Clúster (Helm / Operator) | Compatible |
| Woodpecker MinIO | Woodpecker local (o viceversa) | cualquiera | No compatible |
Evita cambiar de tipo de MQ repetidamente. Si necesitas cambiar, asegúrate de limpiar los datos relacionados antes de cada cambio; los datos residuales pueden provocar un comportamiento inesperado.
