O Milvus suporta quatro MQ: rocksmq (baseado no RockDB), natsmq (servidor nats embutido), Pulsar e Kafka.
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 vários mq neste ficheiro.
modo autónomo (local): rocksmq (predefinição) > natsmq > Pulsar > Kafka
modo de cluster: Pulsar(padrão) > Kafka (rocksmq e natsmq não são suportados no modo cluster)
| Descrição |
Valor por defeito |
|
Valor predefinido: "default" (predefinição)
Valores válidos: [default, pulsar, kafka, rocksmq, natsmq] |
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 |
| Comprimento da memória intermédia do consumidor 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 targe |
16 |
| Descrição |
Valor por defeito |
| Valor por defeito: "3", o tempo limite (em segundos) que o alvo envia msgPack |
3 |
