адаптер потоков dynamodb для KCL в Java SDK v2.x

#amazon-web-services #amazon-dynamodb #amazon-kinesis #amazon-dynamodb-streams

#amazon-веб-сервисы #amazon-dynamodb #amazon-kinesis #amazon-dynamodb-streams

Вопрос:

В AWS есть документ, в котором предлагается наилучший способ использования потока DynamoDB — через клиентскую библиотеку Kinesis с использованием адаптера для перевода между kinesis stream и dynamodb stream API.

Это документ: https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Streams .KCLAdapter.html

И это координаты maven для реализации адаптера

   <groupId>com.amazonaws</groupId>
  <artifactId>dynamodb-streams-kinesis-adapter</artifactId>
  <version>1.5.2</version>
 

Это работает для Java SDK v1.x

Учитывая, что Java SDK v2.x уже некоторое время отсутствует, существует ли эквивалентный адаптер для KCL v2.x? Или, возможно, это каким-то образом встроено в сам SDK?

Ответ №1:

Отвечая на мой собственный вопрос после более подробного изучения.

Похоже, что не существует эквивалента адаптера потоков Dynamodb для KCL 2.x и Java SDK 2.x, поэтому вам нужно будет развернуть свой собственный, если вы хотите использовать поток dynamodb с KCL 2.x.

Кроме того, около 2 недель назад в Dynamodb была добавлена новая функция, которая позволяет передавать изменения элементов непосредственно в потоки Kinesis. Это позволяет использовать KCL 2.x без каких-либо адаптеров. https://aws.amazon.com/about-aws/whats-new/2020/11/now-you-can-use-amazon-kinesis-data-streams-to-capture-item-level-changes-in-your-amazon-dynamodb-table/