Hello Flink dev: We have a number of use cases which involves pulling data from DynamoDB streams into Flink.
Given that this issue is tracked by Flink-4582 <https://issues.apache.org/jira/browse/FLINK-4582>. we would like to check if any prior work has been completed by the community. We are also very interested in contributing to this effort. Currently, we have a high-level proposal which is based on extending the existing FlinkKinesisConsumer and making it work with DynamoDB streams (via integrating with the AmazonDynamoDBStreams API). Any suggestion is welcome. Thank you very much. - Ying