amazon-kinesis

4зной

2ответ

Как узнать, какой процент данных в потоке Kinesis читатель уже обработал? Я знаю, что у каждого читателя есть порядковый номер контрольной точки для каждого шага, и я также могу получить значение Star

4зной

1ответ

Нет метода putRecords на AmazonKinesisClient

Я следую руководству в http://docs.aws.amazon.com/kinesis/latest/dev/kinesis-using-sdk-java-add-data-to-stream.html - перевод примера PutRecords fom java на scala. Я включил amazon-kinesis-client v1.2

1зной

1ответ

Является ли контрольная точка KCL уникальной для приложения/осколка или всего осколка?

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

0зной

1ответ

Проблема Создание потока Кинезиса с помощью Scalazon

Я следую примеру Scalazon в here, чтобы создать поток Kinesis. Следующий фрагмент кода: val streamListFuture = for { s <- Kinesis.streams.list } yield s дает следующее сообщение об ошибке: [er

2зной

1ответ

Как я могу получить самую последнюю запись из потока Amazon Kinesis?

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