mq-bezogene Konfigurationen

Milvus unterstützt vier MQ: rocksmq (basierend auf RockDB), Pulsar, Kafka und Woodpecker.

Sie können Ihr MQ durch Setzen des Feldes mq.type ändern.

Wenn Sie das Feld mq.type nicht als Standard einstellen, finden Sie in dieser Datei einen Hinweis zur Aktivierung der Priorität, wenn wir mehrere MQ konfigurieren.

1. Standalone(lokaler) Modus: rocksmq(Standard) > Pulsar > Kafka

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

3. Woodpecker kann sowohl im Standalone- als auch im Clustermodus verwendet werden, indem mq.type auf woodpecker gesetzt wird.

mq.type

Beschreibung	Standardwert
Standardwert: "Standard" Gültige Werte: [default, pulsar, kafka, rocksmq, woodpecker]	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

mq.dispatcher.maxDispatcherNumPerPchannel

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

mq.dispatcher.retrySleep

Beschreibung	Voreinstellung Wert
register retry sleep time in Sekunden	3

mq.dispatcher.retryTimeout

Beschreibung	Standardwert
Zeitüberschreitung der Registerwiederholung in Sekunden	60