мы публикуем огромные потоки данных в поток aws kinesis с 6 шардами из различных источников, а затем обрабатываем поток, используя одну aws lamda подписку на поток kinesis для обработки записей.
В реальном времени мы наблюдаем огромную задержку, огромные данные в ожидании, которое еще предстоит обработать.
Как мы можем справиться с этим сценарием в безжизненной архитектуре?
Возможно ли это подписаться на определенный шард в aws lamda или создать несколько aws lamda для подписки на тот же поток кинесиса?