mq 相關配置

Milvus 支援四種 MQ:rocksmq(基於 RockDB)、Pulsar、Kafka 和 Woodpecker。

您可以透過設定 mq.type 欄位來變更您的 MQ。

如果您不將 mq.type 欄位設定為預設值,如果我們在此檔案中設定多個 MQ,則會有啟用優先順序的注意事項。

  1. 獨立(本機)模式:rocksmq(預設) > Pulsar > Kafka

  2. 群集模式: Pulsar (預設) > Kafka (群集模式不支援 rocksmq)

  3. 只要將 mq.type 設定為 woodpecker,Woodpecker 就可以在單機和群集模式下使用。

mq.type

說明 預設值
  • 預設值:"default"
  • 有效值:[default, pulsar, kafka, rocksmq, woodpecker] (預設值)
  • 預設值

    mq.enablePursuitMode

    說明 預設值
    預設值:"true" true

    mq.pursuitLag

    說明 預設值
    進入追擊模式的時間勾選滯後閾值,以秒為單位 10

    mq.pursuitBufferSize

    說明 預設值
    追蹤模式緩衝區大小,位元組 8388608

    mq.pursuitBufferTime

    說明 預設值
    追蹤模式緩衝區時間 (秒) 60

    mq.mqBufSize

    說明 預設值
    MQ 用戶端消費者緩衝區長度 16

    mq.dispatcher.mergeCheckInterval

    說明 預設值
    調度員檢查是否合併的時間間隔 (秒) 1

    mq.dispatcher.targetBufSize

    說明 預設值
    用於合併的通道緩衝區長度 16

    mq.dispatcher.maxTolerantLag

    說明 預設值
    預設值:"3",目標傳送 msgPack 的逾時時間(秒)。 3

    mq.dispatcher.maxDispatcherNumPerPchannel

    說明 預設值
    每個實體通道的最大派遣器數量,主要用來限制消費者的數量,並防止效能問題 (例如,在復原期間,當有大量通道被監視時)。 5

    mq.dispatcher.retrySleep

    說明 預設值
    暫存器重試睡眠時間 (秒) 3

    mq.dispatcher.retryTimeout

    說明 預設值
    暫存器重試超時(秒 60