Milvus unterstützt vier MQ: rocksmq (basierend auf RockDB), natsmq (eingebetteter nats-server), Pulsar und Kafka.
Sie können Ihr MQ durch Setzen des Feldes mq.type ändern.
Wenn Sie das Feld mq.type nicht als Standard einstellen, gibt es einen Hinweis zur Aktivierung der Priorität, wenn wir mehrere mq in dieser Datei konfigurieren.
Standalone(lokaler) Modus: rocksmq(Standard) > natsmq > Pulsar > Kafka
Clustermodus: Pulsar(Standard) > Kafka (rocksmq und natsmq werden im Clustermodus nicht unterstützt)
Beschreibung |
Standardwert |
Standardwert: "default"
Gültige Werte: [default, pulsar, kafka, rocksmq, natsmq] |
Standardwert |
Beschreibung |
Standardwert |
Standardwert: "true" |
wahr |
Beschreibung |
Standardwert |
Schwellenwert für den Übergang in den Verfolgungsmodus, in Sekunden |
10 |
Beschreibung |
Standardwert |
Puffergröße des Verfolgungsmodus in Bytes |
8388608 |
Beschreibung |
Standardwert |
Pufferzeit im Verfolgungsmodus in Sekunden |
60 |
Beschreibung |
Standardwert |
Länge des MQ-Client-Verbraucherpuffers |
16 |
Beschreibung |
Standardwert |
die Intervallzeit (in Sekunden), in der der Dispatcher prüft, ob eine Zusammenführung erfolgen soll |
1 |
Beschreibung |
Standardwert |
die Länge des Kanalpuffers für die Zusammenführung |
16 |
Beschreibung |
Standardwert |
Standardwert: "3", der Timeout (in Sekunden), den das Ziel sendet msgPack |
3 |
Beschreibung |
Standardwert |
Die maximale Anzahl der Dispatcher pro physischem Kanal, in erster Linie um die Anzahl der Verbraucher zu begrenzen und Leistungsprobleme zu vermeiden (z. B. während der Wiederherstellung, wenn eine große Anzahl von Kanälen überwacht wird). |
5 |
Beschreibung |
Voreinstellung Wert |
register retry sleep time in Sekunden |
3 |
Beschreibung |
Standardwert |
Zeitüberschreitung der Registerwiederholung in Sekunden |
60 |