History

Prometheus e6a489c76b Scanerror signals the consumer if we should continue scanning for next record & whether to checkpoint. (#54 ) * remove ValidateCheckpoint * update for checkpoint can not customize retryer * implement the scan error as in PR 44 * at least log if record processor has error * mistakenly removed this line * propage error up. ignore invalid state		2018-06-08 08:40:42 -07:00
..
main.go	Scanerror signals the consumer if we should continue scanning for next record & whether to checkpoint. (#54 )	2018-06-08 08:40:42 -07:00
README.md	DDB uses default AWS config settings to ping table; won't work with WithDyanmoClient. Misc update on example and README (#50 )	2018-06-01 16:14:42 -07:00

Consumer

Read records from the Kinesis stream

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

export AWS_ACCESS_KEY=
export AWS_REGION=
export AWS_SECRET_KEY=

$ go run main.go --app appName --stream streamName --table tableName