Veraltet: NATS (natsmq) ist veraltet und wird in Milvus v2.6 entfernt werden. Bitte verwenden Sie stattdessen RocksMQ, Pulsar oder Kafka.

mq-bezogene Konfigurationen

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.

1. Standalone-Modus (lokal): rocksmq (Standard) > natsmq > Pulsar > Kafka

2. Clustermodus: Pulsar(Standard) > Kafka (rocksmq und natsmq werden im Clustermodus nicht unterstützt)

mq.type

Beschreibung	Standardwert
Standardwert: "default" Gültige Werte: [default, pulsar, kafka, rocksmq, natsmq]	Standardwert

mq.enablePursuitMode

Beschreibung	Standardwert
Standardwert: "true"	wahr

mq.pursuitLag

Beschreibung	Standardwert
Schwellenwert für den Übergang in den Verfolgungsmodus, in Sekunden	10

mq.pursuitBufferSize

Beschreibung	Standardwert
Puffergröße des Verfolgungsmodus in Bytes	8388608

mq.pursuitBufferTime

Beschreibung	Standardwert
Pufferzeit im Verfolgungsmodus in Sekunden	60

mq.mqBufSize

Beschreibung	Standardwert
Länge des MQ-Client-Verbraucherpuffers	16

mq.dispatcher.mergeCheckInterval

Beschreibung	Standardwert
die Intervallzeit (in Sekunden), in der der Dispatcher prüft, ob eine Zusammenführung erfolgen soll	1

mq.dispatcher.targetBufSize

Beschreibung	Standardwert
die Länge des Kanalpuffers für die Zusammenführung	16

mq.dispatcher.maxTolerantLag

Beschreibung	Standardwert
Standardwert: "3", der Timeout (in Sekunden), den das Ziel sendet msgPack	3