跳到主要内容
版本：v2.5.x

已废弃：NATS (natsmq) 已被弃用，并将在 Milvus v2.6 中移除。请使用 RocksMQ、Pulsar 或 Kafka 代替。

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​

说明默认值
默认值："truetrue

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