skip to Main Content

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.

3

Answers


  1. 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.

    Login or Signup to reply.
  2. The Apache Flink community is working on it. This is the related PR.

    Login or Signup to reply.
  3. Dynamo DB Sink connector is now available, and details available in official documentation as well.

    A sample application using a custom ElementConverter can be found here. A sample application using the DynamoDbBeanElementConverter can be found here.

    Login or Signup to reply.
Please signup or login to give your own answer.
Back To Top
Search