Мне нужно обрабатывать на пике 100 записей в секунду. Эти записи представляют собой простые тела JSON, и их следует собирать, а затем обрабатывать/преобразовывать в базу данных. Несколько вопросов ... 1) Подходит ли Kinesis для этого? Или SQS...

Я использую amazon-kinesis-connectors для создания клиентского приложения Kinesis. Я выясняю несколько вещей об этом. Как KCL обеспечивает балансировку нагрузки и масштабирование. например у меня стрим с одним шардом и много записей/событий...

Я хочу отложить обработку сообщений из потока AWS Kinesis на один час. Я настроил потребителя KCL для чтения пакета записей каждые четыре минуты, проверки отметки времени каждой записи и остановки обработки пакета, если какая-либо из записей меньше...

Я использую связыватель Spring Cloud Stream Kinesis (версия 2.1.0) По соображениям безопасности у меня должен быть один набор учетных данных для Kinesis и другой набор учетных данных для DynamoDB и CloudWatch. Все работает нормально, если для...