milvus-logo
LFAI
首页
  • 管理指南

mq 相关配置

Milvus 支持四种 MQ:rocksmq(基于 RockDB)、natsmq(嵌入式 nats-server)、Pulsar 和 Kafka。

您可以通过设置 mq.type 字段来更改您的 MQ。

如果不将 mq.type 字段设为默认值,那么如果我们在此文件中配置了多个 mq,就需要注意启用优先级。

  1. 独立(本地)模式:Rocksmq(默认) > Natsmq > Pulsar > Kafka

  2. 集群模式: Pulsar(默认) > Kafka(集群模式下不支持 rocksmq 和 natsmq)

mq.type

说明 默认值
  • 默认值:"默认"
  • 有效值:[默认、pulsar、kafka、rocksmq、natsmq]
  • 默认

    mq.enablePursuitMode

    说明 默认值
    默认值:"true true

    mq.pursuitLag

    说明 默认值
    进入追赶模式的时间勾选滞后阈值,单位为秒 10

    mq.pursuitBufferSize

    描述 默认值
    追赶模式缓冲区大小(字节 8388608

    mq.mqBufSize

    说明 默认值
    MQ 客户端消费者缓冲区长度 16

    mq.dispatcher.mergeCheckInterval

    说明 默认值
    派发器检查是否合并的间隔时间(秒)。 1

    mq.dispatcher.targetBufSize

    说明 默认值
    用于合并的通道缓冲区长度 16

    mq.dispatcher.maxTolerantLag

    说明 默认值
    默认值:3",目标发送 msgPack 的超时(秒)。 3