title: Consume DynamoDB streams in Apache Flink
body: <p>Has anyone tried to consume DynamoDB streams in Apache Flink ?</p>
  
  <p>Flink has a Kinesis consumer. But I am looking for how can i consume the Dynamo stream directly.</p>
  
  <pre><code>DataStream&lt;String&gt; kinesis = env.addSource(new FlinkKinesisConsumer&lt;&gt;(
      "kinesis_stream_name", new SimpleStringSchema(), consumerConfig));
  </code></pre>
  
  <p>I tried searching a lot, but did not find anything. However found an open request pending the Flink Jira board. So I guess this option is not available yet ? What alternatives do I have ?</p>
  
  <p><a href="https://issues.apache.org/jira/browse/FLINK-4582" rel="nofollow noreferrer">Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams</a></p>