Я создаю систему массовой обработки видео с помощью spring -boot. Здесь пользователь предоставит всю информацию, относящуюся к видео, через лист xlsx, а мы обработаем видео в бэкэнде. Я использую Rabbitmq для постановки запроса в очередь. Допустим, пользователь загрузил лист со 100 строками, тогда в очереди Rabbitmq будет 100 сообщений. В бэкэнде мы автоматически масштабируем подписчиков (серверы). Итак, мы начнем с одного подписчика и в зависимости от нагрузки (количества сообщений в очереди) увеличим количество подписчиков до 15. Но наш продюсер очень быстр и распределяет все сообщения нашему первому подписчику (до того, как придут другие подписчики), и все наши новые подписчики не получают сообщений из очереди. Если все подписчики доступны до того, как производитель начал отправлять сообщения, то он распределяет сообщения по всем серверам.
Пожалуйста, дайте мне решение, как наши новые подписчики могут извлекать сообщения из очереди, которые были созданы ранее.
