amazon-kinesis

0зной

1ответ

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

5зной

2ответ

Чтение и запись транзакций в Amazon Kinesis

Я новичок в Kinesis, так что это может показаться очень простым вопросом, но я не смог найти четкого ответа на то, что фактическая разница между транзакцией чтения и записи в потоке Кинезиса. Соответс

7зной

2ответ

Amazon Kinesis + Интеграционные тесты

В настоящее время я работаю над серией веб-сервисов, которые нам нужно интегрировать с Kinesis - реализация выполнена, однако у нас есть серия интеграционных тестов (наши веб-службы используют все Spr

2зной

1ответ

Kinesis GetShardIterator ... недействительна, потому что не из этого потока

У меня есть построить KCL плюс искру базу на https://spark.apache.org/docs/1.2.0/streaming-kinesis-integration.html Я бег это на ОМ (искровой установлено с помощью начальной загрузки). Я создал на пот

0зной

1ответ

Кажется не является приложением клиентской библиотеки Kinesis для искрового плюс KINESIS интеграции

Я иду через код https://github.com/apache/spark/blob/master/extras/kinesis-asl/src/main/java/org/apache/spark/examples/streaming/JavaKinesisWordCountASL.java он показывает, как кинезис может испускать

2зной

1ответ

начать несколько потоков процессора на рабочем месте Spark в одном ядре

Наша ситуация: использование Spark streaming с AWS Kinesis. Если указатель должен быть в памяти как «местный [32]», то Spark может быстро использовать данные из Kinesis. Но если мы перейдем к кластеру

0зной

1ответ

Меньше записей, полученных от Kinesis от AWS SDK для Java

Я использую Java для получения записей от Kinesis, а затем мне придется поместить эти записи в DynamoDB. Проблема в том, что я не получаю все записи в одном экземпляре java. Например, я отправил 72000

0зной

1ответ

Поместите несколько элементов в DynamoDB по Java-коду

Я бы хотел использовать метод batchWriteItem SDK Amazon для размещения большого количества предметов в таблице. Я извлекаю предметы из Кинезиса, и у него много осколков. Я использовал этот метод для о