Java SDK v2.x 中用于 KCL 的 dynamodb 流适配器

dynamodb streams adapter for KCL in Java SDK v2.x

AWS 上的这篇文档建议使用 dynamoDB 流的最佳方式是通过 Kinesis Client Library 使用适配器在 kinesis 流和 dynamodb 流之间进行转换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 本身中?

进一步研究后回答我自己的问题。

似乎没有适用于 KCL 2.x 和 Java SDK 2.x 的 Dynamodb Streams 适配器的等价物,因此如果您想使用,则需要自己推出带有 KCL 2.x.

的 dynamodb 流

此外,大约 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/