Configurações relacionadas com mq

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.

1. modo autónomo (local): rocksmq (predefinição) > natsmq > Pulsar > Kafka

2. modo de cluster: Pulsar(padrão) > Kafka (rocksmq e natsmq não são suportados no modo cluster)

mq.type

Descrição	Valor por defeito
Valor predefinido: "default" (predefinição) Valores válidos: [default, pulsar, kafka, rocksmq, natsmq]	predefinição

mq.enablePursuitMode

Descrição	Valor por defeito
Valor predefinido: "true" (verdadeiro)	verdadeiro

mq.pursuitLag

Descrição	Valor por defeito
limiar de desfasamento para entrar no modo de perseguição, em segundos	10

mq.pursuitBufferSize

Descrição	Valor por defeito
tamanho da memória intermédia do modo de perseguição, em bytes	8388608

mq.mqBufSize

Descrição	Valor por defeito
Comprimento da memória intermédia do consumidor cliente MQ	16

mq.dispatcher.mergeCheckInterval

Descrição	Valor por defeito
o intervalo de tempo (em segundos) para o expedidor verificar se deve fundir	1

mq.dispatcher.targetBufSize

Descrição	Valor por defeito
o comprimento da memória intermédia do canal para targe	16

mq.dispatcher.maxTolerantLag

Descrição	Valor por defeito
Valor por defeito: "3", o tempo limite (em segundos) que o alvo envia msgPack	3