Hi Anoop, Currently, Samza has built-in support for consuming data from AWS Kinesis. As a short-term solution, if you want to consume from "Dynamo DB Streams", you can certainly pipe it to Kinesis and write a Samza job that consume from it.
Please see: Consuming from Kinesis <https://samza.apache.org/learn/documentation/0.14/aws/kinesis.html> Sample application that reads from Kinesis <https://github.com/apache/samza-hello-samza/blob/master/src/main/java/samza/examples/kinesis/KinesisHelloSamza.java> I did an initial analysis on what it would take to support "Dynamo DB Streams" natively in Samza and filed SAMZA-1799 <https://issues.apache.org/jira/browse/SAMZA-1799> to track it. It should be possible to support this with relatively minimal effort. Thanks! Jagadish On Thu, Aug 2, 2018 at 5:14 AM, Anoop Krishnakumar < anoop.krishnaku...@gmail.com> wrote: > Hello, > > Is there an example or documentation on how to use dynamodb as source > stream ? > > -anoop > -- Jagadish V, Graduate Student, Department of Computer Science, Stanford University
