Мы планируем использовать сообщения из потока Kinesis. Нам нужно обрабатывать данные событий по одному (без окон, без агрегации), и мы могли видеть несколько вариантов чтения данных из потока kinesis: ...