amazon-kcl

1зной

1ответ

Как справиться с этим, когда процессRecords не прошел в AWS KCL?

Я создаю приложение с nodejs на основе KCL. в функции processRecords, я попытался отправить записи, которые я получаю от кинезиса, к веб-службе с помощью http-запроса. Но когда веб-служба недоступна,

0зной

1ответ

kinesis client worker logic

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

0зной

2ответ

Как повторить KINESIS записи с KCL C#

Я хочу Replay KINESIS записей по заданному TimeSpan, (или время начала) использования: на сбоя приложения, некоторые потоковые записи могут быть считается обработанным, но фактически не завершенным. т

3зной

1ответ

Журналы клиентской библиотеки Dump Kinesis (KCL) записываются в файл

Am используют библиотеку клиентов Kinesis (KCL) для подписки на поток кинезий. Все журналы KCL печатаются на консоли. Мне нужно сбросить все журналы в файл. Я попытался добавить файлы log4j.properties

1зной

1ответ

Является ли Kinesis правильным инструментом для моих нужд? (& другие сортированные вопросы)

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

1зной

1ответ

Исключение, когда python KCL подключается к потоку kinesis

Я пытаюсь интегрировать кинезис в искровой потоковой передаче, и для этого я использую python и KCL. Я получаю это исключение в большинстве случаев при чтении из кинезиса кодек «utf8» не может декодир