Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-24438 Port Kinesis Source to new Source API (FLIP-27)
  3. FLINK-34341

Add support for DDB Streams for DataStream API

    XMLWordPrintableJSON

Details

    Description

       

      In the legacy KDS source we support Amazon DynamoDB streams via an adapter shim. Both KDS and DDB streams have a similar API.

      This task builds upon https://issues.apache.org/jira/browse/FLINK-34339 and will add a DynamoDBStreamsSource which will setup a DDB SDK client shim.

      Attachments

        Issue Links

          blocks

          Sub-task - The sub-task of the issue FLINK-34340 Implement DDB Streams Table API support

          • Major - Major loss of function.
          • Open

          Sub-task - The sub-task of the issue FLINK-34342 Address Shard Consistency Issue for DDB Streams Source

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #146

          Activity

            People

              gguptp Abhi Gupta
              dannycranmer Danny Cranmer
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: