Как только брокер отправляет сообщения потребителю, брокер не может просто вызвать их, поскольку потребитель может их обрабатывать. Потребитель должен отменить сообщения обратно в очередь (например, закрыв соединение / сеанс).
Я бы порекомендовал настроить ваш consumerWindowSize (установленный на URL-адресе клиента) так, чтобы подходящее количество сообщений рассылается вашим потребителям. По умолчанию consumerWindowSize составляет 1 МБ (1024 * 1024 байта). Меньшее значение consumerWindowSize будет означать, что больше клиентов смогут получать сообщения одновременно, но это также будет означать, что клиенты должны будут выполнять больше обходов в сети, чтобы сказать брокеру отправлять больше сообщений, когда они заканчивают работу. Вам нужно будет выполнить тесты, чтобы найти правильное значение consumerWindowSize для вашего случая использования и производительности.