Configuraciones relacionadas con mq

Milvus soporta cuatro MQ: rocksmq(basado en RockDB), Pulsar, Kafka y Woodpecker.

Puede cambiar su mq configurando el campo mq.type.

Si no estableces el campo mq.type como predeterminado, hay una nota acerca de habilitar la prioridad si configuramos múltiples mq en este archivo.

  1. modo standalone(local): rocksmq(por defecto) > Pulsar > Kafka

  2. modo cluster: Pulsar(por defecto) > Kafka (rocksmq no está soportado en modo cluster)

  3. Woodpecker se puede utilizar tanto en modo autónomo como en modo clúster estableciendo mq.type como woodpecker.

mq.type

Descripción Valor por defecto
  • Valor por defecto: "default"
  • Valores válidos: [default, pulsar, kafka, rocksmq, woodpecker]
  • por defecto

    mq.enablePursuitMode

    Descripción Valor por defecto
    Valor por defecto: "true" verdadero

    mq.pursuitLag

    Descripción Valor por defecto
    umbral de retardo para entrar en modo de persecución, en segundos 10

    mq.pursuitBufferSize

    Descripción Valor por defecto
    tamaño del búfer del modo de persecución, en bytes 8388608

    mq.pursuitBufferTime

    Descripción Valor por defecto
    tiempo del búfer del modo pursuit en segundos 60

    mq.mqBufSize

    Descripción Valor por defecto
    Longitud del búfer de consumidor de cliente MQ 16

    mq.dispatcher.mergeCheckInterval

    Descripción Valor por defecto
    el tiempo de intervalo (en segundos) para que el despachador compruebe si fusionar 1

    mq.dispatcher.targetBufSize

    Descripción Valor por defecto
    Longitud del búfer del canal para la fusión 16

    mq.dispatcher.maxTolerantLag

    Descripción Valor por defecto
    Valor por defecto: "3", el tiempo de espera(en segundos) que el objetivo envía msgPack 3

    mq.dispatcher.maxDispatcherNumPerPchannel

    Descripción Valor por defecto
    El número máximo de despachadores por canal físico, principalmente para limitar el número de consumidores y evitar problemas de rendimiento (por ejemplo, durante la recuperación cuando se vigila un gran número de canales). 5

    mq.dispatcher.retrySleep

    Descripción Valor por defecto
    tiempo de espera de reintento de registro en segundos 3

    mq.dispatcher.retryTimeout

    Descripción Valor por defecto
    tiempo de espera de reintento de registro en segundos 60