Looks like it confirms to the spec (the field is not provided for dynamodb streams - wouldn't make sense either): https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_streams_GetRecords.html
We are internally using the consumer to process the dynamodb CDC stream, plan is to add the complete support to the Kinesis connector soon. [ Full content available at: https://github.com/apache/flink/pull/6708 ] This message was relayed via gitbox.apache.org for [email protected]
