小编Rap*_*ère的帖子

我想从Spark Streaming应用程序使用DynamoDB流。

Spark流使用KCL读取Kinesis。有一个使KCL能够从DynamoDB流读取的库：dynamodb-streams-kinesis-adapter。

但是有可能将此lib插入spark吗？有人这样做吗？

我正在使用Spark 2.1.0。

我的备份计划是让另一个应用程序从DynamoDB流读取到Kinesis流中。

谢谢