O Milvus suporta quatro MQ: rocksmq (baseado no RockDB), Pulsar, Kafka e Woodpecker.
Pode alterar o seu mq definindo o campo mq.type.
Se não definir o campo mq.type como predefinido, existe uma nota sobre a ativação da prioridade se configurarmos múltiplos mq neste ficheiro.
modo autónomo (local): rocksmq (predefinição) > Pulsar > Kafka
modo de cluster: Pulsar(padrão) > Kafka (rocksmq não é suportado no modo cluster)
O Woodpecker pode ser usado tanto no modo autónomo como no modo cluster, definindo mq.type para woodpecker.
| Descrição |
Valor predefinido |
|
Valor predefinido: "default"
Valores válidos: [default, pulsar, kafka, rocksmq, woodpecker] |
predefinição |
| Descrição |
Valor por defeito |
| Valor predefinido: "true" (verdadeiro) |
verdadeiro |
| Descrição |
Valor por defeito |
| limiar de desfasamento para entrar no modo de perseguição, em segundos |
10 |
| Descrição |
Valor por defeito |
| tamanho da memória intermédia do modo de perseguição, em bytes |
8388608 |
| Descrição |
Valor por defeito |
| Tempo da memória intermédia do modo de perseguição, em segundos |
60 |
| Descrição |
Valor por defeito |
| Comprimento da memória intermédia do cliente MQ |
16 |
| Descrição |
Valor por defeito |
| o intervalo de tempo (em segundos) para o expedidor verificar se deve fundir |
1 |
| Descrição |
Valor por defeito |
| o comprimento da memória intermédia do canal para o targe |
16 |
| Descrição |
Valor por defeito |
| Valor por defeito: "3", o tempo limite (em segundos) que o alvo envia msgPack |
3 |
| Descrição |
Valor por defeito |
| O número máximo de expedidores por canal físico, principalmente para limitar o número de consumidores e evitar problemas de desempenho (por exemplo, durante a recuperação quando um grande número de canais é observado). |
5 |
| Descrição |
Valor predefinido |
| tempo de espera de repetição de registo em segundos |
3 |
| Descrição |
Valor por defeito |
| tempo limite de repetição do registo em segundos |
60 |
