tree 8aa6f7efda372cb52a2db79297f379cf43d9f7ea
parent 95bf642fa9d7c9917f45b51e3e89e53e16e56ae5
author Jacob Burroughs <maths22@gmail.com> 1589901411 -0500
committer GitHub <noreply@github.com> 1589901411 +0800

Add dynamodb streams source (#6874)

### Motivation

The goal is to allow consuming dynamodb streams directly into pulsar

### Modifications

I created a new source for dynamo, which shares less code than ideal with the kinesis source, since the dynamodb kinesis client adapter supports KCL v1.x only, while, the kinesis source is using KCL v2.x.  I also abstracted the aws credential management pieces into their own package.

### Verifying this change

Create a dynamodb table with streams enabled.  Configure this connector with the stream ARN and appropriate credentials.  Create/update an entry in the table and ensure it is written to pulsar by the connector.