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