shikhar / kafka-connect-dynamodb

Kafka Connector for DynamoDB
Apache License 2.0
34 stars 50 forks source link

Added updateItem functionlity #13

Open orsher opened 7 years ago

orsher commented 7 years ago

The connector currently only support putItem DynamoDB api. putItem replaces the whole item. If someone want to change only the available set of columns and leave the rest untouched it's not possible.

I added support for using the updateItem api. In order to use it, one should use the following configurations: use.updates = "true" tables.keys.names = ["hash_key_attribute_name", "range_key_attribute_name"]

Change should be totally backward compatible.