I think the consumer should also work for dynamodb streams, the plan is to add the full support soon (https://issues.apache.org/jira/browse/FLINK-4582).
[ Full content available at: https://github.com/apache/flink/pull/6708 ] This message was relayed via gitbox.apache.org for [email protected]
