Обзор очереди сообщений
Milvus использует очередь сообщений (журнал предварительной записи, WAL) для управления журналами недавних изменений, журналами выходных потоков и обеспечения подписок на журналы. В Milvus 3.x по умолчанию используется Woodpecker, который не требует отдельной инфраструктуры обмена сообщениями. Pulsar, Kafka и RocksMQ по-прежнему поддерживаются для определенных сценариев.
Поддерживаемые очереди сообщений
| Очередь сообщений | Автономная версия Milvus | Распределенная версия Milvus (кластер) | По умолчанию в | Примечания |
|---|---|---|---|---|
| Woodpecker | ✔️ (встроенный) | ✔️ (встроенный или в виде службы) | Milvus 3.x (оба режима) | По умолчанию и рекомендуется. Облачный WAL в объектном хранилище; внешний сервис не требуется. |
| Pulsar | ✔️ | ✔️ | ≤ 2.5.x (по умолчанию для кластера) | Поддерживается, внешний или входящий в состав. |
| Kafka | ✔️ | ✔️ | — | Поддерживается. Только Kafka 2.x или 3.x. |
| RocksMQ | ✔️ | ✖️ | ≤ 2.5.x (автономный режим по умолчанию) | Поддерживается только для автономного режима. |
Каждый экземпляр Milvus использует ровно одну очередь сообщений.
Ограничения, связанные сочередью сообщений: при обновлении до Milvus v3.0.0 необходимо сохранить текущий выбор очереди сообщений. Переключение между различными системами очередей сообщений во время обновления не поддерживается. Поддержка смены систем очередей сообщений будет доступна в будущих версиях.
Чтобы изменить очередь сообщений для запущенного экземпляра, см. раздел «Смена очереди сообщений». Функция «Смена MQ» доступна в Milvus 3.0 и более поздних версиях — сначала обновите систему до Milvus 3.0 или более поздней версии.
Выбор очереди сообщений
- Новые развертывания (Milvus 3.x): используйте Woodpecker (по умолчанию). В автономном режиме он работает встроенным; для распределенной (кластерной) конфигурации рекомендуемым вариантом по умолчанию является выделенный сервис, развернутый с помощью Helm, при этом также поддерживается встроенный режим.
- Существующие пользователи Pulsar или Kafka: Pulsar и Kafka по-прежнему полностью поддерживаются. Можно оставить их или перейти на Woodpecker.
- RocksMQ: поддерживается только в автономном режиме и заменен встроенным Woodpecker в Milvus 3.x.