mq 相关配置
Milvus 支持四种 MQ:rocksmq(基于 RockDB)、natsmq(嵌入式 nats-server)、Pulsar 和 Kafka。
您可以通过设置 mq.type 字段来更改您的 MQ。
如果不将 mq.type 字段设为默认值,那么如果我们在此文件中配置了多个 mq,就需要注意启用优先级。
独立(本地)模式:Rocksmq(默认) > Natsmq > Pulsar > Kafka
集群模式: Pulsar(默认) > Kafka(集群模式下不支持 rocksmq 和 natsmq)
mq.type
说明 | 默认值 |
---|---|
|
默认 |
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 |