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 |