kinesis-consumer/examples/consumer/cp-dynamo/README.md

# Consumer

Read records from the Kinesis stream

### Environment Variables

Export the required environment vars for connecting to the Kinesis stream:

```
export AWS_ACCESS_KEY=
export AWS_REGION=
export AWS_SECRET_KEY=
```

### Run the consumer

    $ go run main.go --app appName --stream streamName --table tableName
Simplify the consumer experience (#35) Major changes: * Remove intermediate batching of kinesis records * Call the callback func with each record * Use functional options for config https://dave.cheney.net/2014/10/17/functional-options-for-friendly-apis Minor changes: * update README messaging about Kinesis -> Firehose functionality * remove unused buffer and emitter code 2017-11-20 16:21:40 +00:00			`# Consumer`

			`Read records from the Kinesis stream`

			`### Environment Variables`

			`Export the required environment vars for connecting to the Kinesis stream:`

			```
			`export AWS_ACCESS_KEY=`
Correct AWS_REGION (#48) 2018-05-30 13:45:38 +00:00			`export AWS_REGION=`
Simplify the consumer experience (#35) Major changes: * Remove intermediate batching of kinesis records * Call the callback func with each record * Use functional options for config https://dave.cheney.net/2014/10/17/functional-options-for-friendly-apis Minor changes: * update README messaging about Kinesis -> Firehose functionality * remove unused buffer and emitter code 2017-11-20 16:21:40 +00:00			`export AWS_SECRET_KEY=`
			```

			`### Run the consumer`

DDB uses default AWS config settings to ping table; won't work with WithDyanmoClient. Misc update on example and README (#50) 2018-06-01 23:14:42 +00:00			`$ go run main.go --app appName --stream streamName --table tableName`