Mudança da fila de mensagens
Este guia descreve como alternar a fila de mensagens (MQ) de uma implementação existente do Milvus entre o Woodpecker e outra fila de mensagens, em linha e sem tempo de inatividade.
Esta funcionalidade está pendente de lançamento e está sujeita a alterações. Contacte o suporte do Milvus se quiser experimentá-la ou se tiver alguma dúvida.
Pré-requisitos
- A funcionalidade «Mudar MQ» está disponível no Milvus 3.0 e versões posteriores. Atualize a sua instância do Milvus para a versão 3.0 ou posterior antes de a utilizar — a funcionalidade não está disponível em versões anteriores.
- A instância está a funcionar corretamente.
Âmbito
Este guia aborda apenas a alternância entre o Woodpecker e outra fila de mensagens. A alternância direta entre o Pulsar e o Kafka está fora do âmbito deste guia.
- Alternar entre o RocksMQ e o Woodpecker — Milvus Standalone (Docker Compose)
- Alternar entre o Pulsar e o Woodpecker — cluster do Milvus (Helm / Milvus Operator)
- Mudança entre o Kafka e o Woodpecker — cluster Milvus (Helm / Milvus Operator)
Fluxo de trabalho geral
- Certifique-se de que a instância do Milvus está a funcionar corretamente.
- Confirme o tipo de MQ de origem e o tipo de MQ de destino.
- Aplique as definições de acesso do MQ de destino à configuração do Milvus sem alterar o valor de «
mqType». - Acionar a alternância chamando a API WAL alter no MixCoord.
- Monitorize os registos para confirmar que a transição foi concluída.
Antes da transição, certifique-se de que o MQ de destino não contém tópicos com os mesmos nomes que os utilizados pela instância atual do Milvus. Isto é especialmente importante se o MQ de destino tiver sido utilizado por outra instância do Milvus, uma vez que nomes de tópicos em conflito podem levar a comportamentos inesperados.
Matriz de suporte
| MQ de origem | MQ de destino | Implementação | Estado |
|---|---|---|---|
| RocksMQ | Woodpecker (local/MinIO) | Autónomo (Docker Compose) | Compatível |
| Woodpecker (local/MinIO) | RocksMQ | Autónomo (Docker Compose) | Compatível |
| Pulsar (integrado/externo) | Woodpecker (MinIO) | Cluster (Helm / Operator) | Compatível |
| Woodpecker (MinIO) | Pulsar (externo) | Cluster (Helm / Operator) | Compatível |
| Kafka (integrado/externo) | Woodpecker (MinIO) | Cluster (Helm / Operator) | Compatível |
| Woodpecker (MinIO) | Kafka (externo) | Cluster (Helm / Operator) | Compatível |
| Woodpecker MinIO | Woodpecker local (ou vice-versa) | qualquer | Não suportado |
Evite alternar repetidamente entre tipos de MQ. Se for necessário alternar, certifique-se de que limpa os dados relacionados antes de cada alternância — os dados residuais podem causar um comportamento inesperado.
