Я запускаю автономный apache-pulsar на своем локальном компьютере в качестве контейнера докеров для системы очередей и отправляю 1000 заданий в одну тему (скажем, «демо»).
Если у меня есть 1 потребитель, который слушает «демонстрационную» тему, обрабатывает задание и подтверждает (в пределах 100-500 мс). Все работы выполняются примерно за 80 секунд.
Но если я проведу тот же тест на 1000 заданий с большим количеством потребителей (2 или 4 потребителя), общая пропускная способность останется такой же, как около 80 секунд.
Я не уверен, не хватает ли мне некоторых необходимых конфигураций, или мне понадобится несколько брокеров Pulsar, или что мне делать, чтобы при увеличении количества потребителей пропускная способность также увеличилась (например, около 40-45 секунд в случае 2 потребителей).
Образ докера: apachepulsar / pulsar
параметры потребителя: "subscriptionType": "Shared", "ReceiverQueueSize": 100, "ackTimeoutMillis": 1200000
Спасибо!
