У меня есть быстрый вопрос. Может ли KCL потреблять данные из нескольких потоков? Стоит ли вам когда-либо настраивать несколько потоков для своего приложения или отдельный поток должен быть привязан к отдельному приложению? Мой конкретный вариант...

Я хочу понять, когда метод processRecords IRecordProcessor вызывается из worker. Если мой предыдущий вызов processRecords еще не завершен, будет ли рабочий вызывать следующий processRecords? Начнет ли worker извлекать новые записи из kinesis или...

Я пытаюсь перекачивать много данных через Amazon Kinesis (порядка 10 000 точек в секунду). Чтобы максимизировать количество записей в секунду через мои осколки, я хотел бы выполнять циклический перебор моих запросов по осколкам (логика моего...

Я заполняю записи в dynamodb в следующей последовательности: A11, A12, A13, A14, A15, A21, A22, A23, A24, A25, A31, A32, A33, A34, A35 Записи с одинаковым префиксом (Ai) имеют один и тот же ключ раздела, но разные ключи сортировки....

Я работаю над приложением для мониторинга микросервисов. Мое приложение предполагает соответствующее обновление графического интерфейса при получении новой потребляемой записи, что означает: Когда я получаю новую запись: 1) Я проверяю, является ли...

Мы используем kinesis flink connector , чтобы потреблять и производить записи в кинезис из флинка. Поскольку он использует KCL , он должен делать записи в dynamoDB со смещением для потоков кинезиса, которые он потребляет. Мы не видим никаких...

У меня есть потребитель Kinesis, чья работа заключается в отслеживании текущих активных пользователей в системе. Каждую минуту пользователи отправляют контрольный сигнал в поток Kinesis, и эта система просто хранит список всех уникальных...

Постановка задачи Я написал программу, которая использует DynamoDb Streams для получения уведомлений об обновлении, этот код отлично работает при использовании сервисов AWS, но, похоже, не работает с использованием Testcontainers / Localstack для...