, поэтому я читал этот учебник для настройки RabbitMQ и SpringBoot.
В определенный момент сказано:
В большинстве случаев нам нужно, чтобы сообщение было обработано только один раз.
Spring Cloud Stream реализует это поведение через группы потребителей.
Итак, я начал искать дополнительную информацию о Spring docs написано, что:
При этом различные экземпляры приложения помещаются в
конкурирующие потребительские отношения, где только один из примеров
ожидается, что обработает данное сообщение.
Spring Cloud Stream моделирует это поведение с помощью концепции
группа потребителей. (Группы потребителей Spring Cloud Stream похожи на
и вдохновлен группами потребителей Kafka.)
Итак, я настроил здесь два узла с Spring Boot Cloud Stream и RabbitMQ и с использованием spring.cloud.stream.bindings.<channel>.group.
Для меня это все еще выглядит как минимум одноразовое поведение. Я ошибаюсь, предполагая это? Должен ли я по-прежнему управлять возможностью обрабатывать сообщение дважды, даже используя spring.cloud.stream.bindings.<channel>.group?
Спасибо