Использование AWS Kinesis Data Stream с несколькими шардами с использованием KCL в узле js
У нас есть один производитель и один поток данных Kinesis. Для достижения более высокой пропускной способности нам нужно несколько осколков. Поместить данные на несколько сегментов в поток данных Kinesis - это хорошо. Как я могу использовать данные из нескольких шардов в одном приложении nodejs? Сбой потребительского приложения, поскольку процессор записей пытается выполнить несколько процессов на основе количества сегментов. Процессор записи не работает на определенном порту, говоря, что "порт уже используется"
Любая помощь ценится за дизайн и концепцию.