Configurazioni relative a mq

Milvus supporta quattro MQ: rocksmq (basato su RockDB), Pulsar, Kafka e Woodpecker.

È 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.

  1. modalità standalone (locale): rocksmq (predefinito) > Pulsar > Kafka

  2. modalità cluster: Pulsar (predefinito) > Kafka (rocksmq non è supportato in modalità cluster).

  3. Woodpecker può essere usato sia in modalità standalone che in cluster impostando mq.type su woodpecker.

mq.type

Descrizione Valore predefinito
  • Valore predefinito: "default"
  • Valori validi: [default, pulsar, kafka, rocksmq, woodpecker].
  • default

    mq.enablePursuitMode

    Descrizione Valore predefinito
    Valore predefinito: "true" vero

    mq.pursuitLag

    Descrizione Valore predefinito
    tempo soglia di ritardo per entrare in modalità inseguimento, in secondi 10

    mq.pursuitBufferSize

    Descrizione Valore predefinito
    dimensione del buffer della modalità di inseguimento in byte 8388608

    mq.pursuitBufferTime

    Descrizione Valore predefinito
    tempo buffer modalità inseguimento in secondi 60

    mq.mqBufSize

    Descrizione Valore predefinito
    Lunghezza del buffer del client consumer MQ 16

    mq.dispatcher.mergeCheckInterval

    Descrizione Valore predefinito
    l'intervallo di tempo (in secondi) in cui il dispatcher controlla se unire o meno 1

    mq.dispatcher.targetBufSize

    Descrizione Valore predefinito
    la lunghezza del buffer del canale per il targe 16

    mq.dispatcher.maxTolerantLag

    Descrizione Valore predefinito
    Valore predefinito: "3", il timeout (in secondi) che il target invia a msgPack 3

    mq.dispatcher.maxDispatcherNumPerPchannel

    Descrizione Valore predefinito
    Il numero massimo di dispatcher per canale fisico, principalmente per limitare il numero di consumatori e prevenire problemi di prestazioni (ad esempio, durante il ripristino quando viene osservato un gran numero di canali). 5

    mq.dispatcher.retrySleep

    Descrizione Valore predefinito
    tempo di sospensione dei tentativi di registrazione in secondi 3

    mq.dispatcher.retryTimeout

    Descrizione Valore predefinito
    timeout di riprova del registro in secondi 60