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流。这样就可以在不使用任何适配器的情况下使用KCL2.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-你的amazon-dynamodb表/