luciano/kinesis-consumer
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions
kinesis-consumer/examples/consumer
History
Prometheus 9e0a97916d Use AWS resource iface, overwrite default dynamodb, more explicit in example about overwrite default AWS resrouce client (#49) 
* use custom kinesis client

* use aws sdk interface, add missing api for ddb

* add overwrite default dynamodbclien usage
2018-05-31 17:41:14 -07:00
..
main.go Use AWS resource iface, overwrite default dynamodb, more explicit in example about overwrite default AWS resrouce client (#49) 2018-05-31 17:41:14 -07:00
README.md Correct AWS_REGION (#48) 2018-05-30 06:45:38 -07:00

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