I have a pull request that I want to submit.
Basically, DynamoDB has a stream and amazon recommends using the kinesis adapter dynamo stream client. So, I've modified the configuration to accept the adapter as a parameter (can be done also with a flag I guess) and the worker puts the adapter in place of the KinesisClient.
Also, the user that wants to read from a dynamo stream just needs to provide a KinesisRecordReader implicitly which takes into account the EventName which is basically the dynamodb operation.
Would you be interested in this feature?