package
0.3.6-alpha
Repository: https://github.com/lepek/kinesis-consumer.git
Documentation: pkg.go.dev
# README
Consumer with postgres checkpoint
Read records from the Kinesis stream using postgres as checkpoint
Run the consumer
go run main.go --app appName --stream streamName --table tableName --connection connectionString