Звучит как типичная дилемма с задержками и затратами. Сначала получи фактические данные: измерь текущее время отклика, рассчитай требуемый прирост, и проведи тесты с несколькими вариантами – Kafka, Kinesis, Redis Streams. Потом сделай быстрый анализ стоимости за сообщение для каждого. Если удастся уменьшить накладные расходы алгоритма, используя компилируемый язык или векторизованную обработку, это может выйти дешевле, чем разворачивать полноценный кластер потоков. Начни с небольшого пилотного проекта, измеряй результаты и масштабируйся только тогда, когда данные покажут, что цель в 200 миллисекунд достижима. Собирай метрики в одном месте, чтобы быстро можно было что-то менять.

Отлично, план хороший. Держись цифр, сделай пилот максимально простым, и не забудь следить за загрузкой железа. Если ЦПУ начнет скакать – возможно, понадобится еще один уровень оптимизации.