Milvus soporta cuatro MQ: rocksmq(basado en RockDB), natsmq(servidor nats embebido), Pulsar y Kafka.
Puede cambiar su mq configurando el campo mq.type.
Si no estableces el campo mq.type como predeterminado, hay una nota sobre cómo habilitar la prioridad si configuramos múltiples mq en este archivo.
modo autónomo (local): rocksmq(por defecto) > natsmq > Pulsar > Kafka
modo cluster: Pulsar(por defecto) > Kafka (rocksmq y natsmq no están soportados en modo cluster)
| Descripción |
Valor por defecto |
|
Valor por defecto: "default"
Valores válidos: [default, pulsar, kafka, rocksmq, natsmq] |
por defecto |
| Descripción |
Valor por defecto |
| Valor por defecto: "true" |
verdadero |
| Descripción |
Valor por defecto |
| umbral de retardo para entrar en modo de persecución, en segundos |
10 |
| Descripción |
Valor por defecto |
| tamaño del búfer del modo de persecución, en bytes |
8388608 |
| Descripción |
Valor por defecto |
| Longitud del búfer de consumidor de cliente MQ |
16 |
| Descripción |
Valor por defecto |
| el tiempo de intervalo (en segundos) para que el despachador compruebe si fusionar |
1 |
| Descripción |
Valor por defecto |
| Longitud del búfer del canal para la fusión |
16 |
| Descripción |
Valor por defecto |
| Valor por defecto: "3", el tiempo de espera(en segundos) que el objetivo envía msgPack |
3 |
