Maybe others can answer more directly from personal experience about reading streams using the existing DynamoDBIO connector, but it doesn’t seem to support streams looking at the source and doc.
I haven’t done this myself, but it looks as though Kinesis is “the recommended was to consume streams from Amazon DynamoDB”. I also found this [1] guided example of using Beam with Kineses Data Analytics. It might not be exactly what you’re after, but maybe there are some good building blocks? Hope there’s something helpful in there. [1] https://docs.aws.amazon.com/kinesisanalytics/latest/java/examples-beam.html On Sat, Apr 3, 2021 at 13:24 Tao Li <t...@zillow.com> wrote: > Hi Beam community, > > > > Does Beam DynamoDBIO support ingesting DynamoDB Streams > <https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Streams.html>? > Thanks! >
