Milvus supporta quattro MQ: rocksmq (basato su RockDB), natsmq (server nats incorporato), Pulsar e Kafka.
È possibile cambiare il proprio MQ impostando il campo mq.type.
Se non si imposta il campo mq.type come predefinito, c'è una nota sull'abilitazione della priorità se si configurano più mq in questo file.
modalità standalone (locale): rocksmq (predefinito) > natsmq > Pulsar > Kafka
modalità cluster: Pulsar (predefinito) > Kafka (rocksmq e natsmq non sono supportati in modalità cluster).
| Descrizione |
Valore predefinito |
|
Valore predefinito: "default"
Valori validi: [default, pulsar, kafka, rocksmq, natsmq]. |
default |
| Descrizione |
Valore predefinito |
| Valore predefinito: "true" |
vero |
| Descrizione |
Valore predefinito |
| soglia di ritardo per entrare in modalità inseguimento, in secondi |
10 |
| Descrizione |
Valore predefinito |
| dimensione del buffer della modalità di inseguimento in byte |
8388608 |
| Descrizione |
Valore predefinito |
| Lunghezza del buffer del client consumer MQ |
16 |
| Descrizione |
Valore predefinito |
| l'intervallo di tempo (in secondi) in cui il dispatcher controlla se unire o meno |
1 |
| Descrizione |
Valore predefinito |
| la lunghezza del buffer del canale per il targe |
16 |
| Descrizione |
Valore predefinito |
| Valore predefinito: "3", il timeout (in secondi) che il target invia a msgPack |
3 |
