How can DynamoDB be used as a sink to an AWS Data Analytics Application (Flink)?

I'm not finding examples or an existing DynamoDB Sink implementation class.

CodePudding user response：

There is no official DynamoDB connector for Flink.

However, there are various third party ones such as

https://github.com/klarna-incubator/flink-connector-dynamodb

Or

https://github.com/fabricalab/streaming-flink-dynamodb-connector

I would strongly suggest that you test any third party connectors to ensure they are production ready and suit your needs.

CodePudding user response：

An apache flink developer is working on it. And this is the related PR.

Now the MongoDB connector will be migrated to a new repository.