Я настроил кластер RabbitMQ в k8s, сформированный из 3 контейнеров. Я хотел бы загрузить MQTT-сообщения баланса, поступающие в конкретную тему, используя плагин шардинга , чтобы сообщения распределялись «разумно равномерно» между шардами, по 1 шарду на узел. Моя проблема в том, что после настройки все сообщения не распределяются равномерно по осколкам.
Вот моя конфигурация:
- Я создаю следующую политику:
- Я создаю следующий обмен:
- Я связываю amq.topic с shard.exchange.
Все сообщения попадают в одну очередь:
ЛЮБЫЕ ИДЕИ?