Amazon Kinesis Client for Go

Find a file

Nathan Leiby 267b28a032 Remove self-references in Gopkg.toml Issue: https://clever.atlassian.net/browse/IL-200 We accidentally introduced self-references into some Gopkg.toml files. Let's remove them! More context: https://github.com/golang/dep/issues/1690		2018-02-16 14:24:35 -08:00
batchconsumer	add test for default case	2018-01-25 15:13:11 +00:00
cmd	remove logger as parameter	2017-11-03 17:48:50 +00:00
decode	Removed stringifyNested, renameESReservedFields, and minimumTimestamp params from decoder. minimumTimestamp isn't needed anymore. stringifyNested and renameESReservedFields are very specific to the elasticsearch consumer and will be moved to the elasticsearch consumer.	2017-09-21 19:51:48 +00:00
kcl	Cleaned up shutdown code	2017-09-20 21:28:43 +00:00
splitter	add test for default case	2018-01-25 15:13:11 +00:00
.gitignore	Added vendor to .gitignore	2017-05-22 22:57:34 +00:00
batchconsumer.properties	Implemented new consumer interface as well as example consumer: 'batchconsumer'	2017-07-18 02:03:15 +00:00
circle.yml	upgrade to 1.9 and convert to dep	2017-11-08 09:46:29 -08:00
consumer.properties	initial commit	2017-02-08 20:23:00 +00:00
golang.mk	add test for default case	2018-01-25 15:13:11 +00:00
Gopkg.lock	Remove self-references in Gopkg.toml	2018-02-16 14:24:35 -08:00
Gopkg.toml	Remove self-references in Gopkg.toml	2018-02-16 14:24:35 -08:00
Makefile	add test for default case	2018-01-25 15:13:11 +00:00
README.md	initial commit	2017-02-08 20:23:00 +00:00

amazon-kinesis-client-go

Running the Consumer

Edit the file consumer.properties to point at a Kinesis stream that has some data. Build the consumer binary:

make build

Then run:

make run

This will download the jar files necessary to run the KCL, and then launch the KCL communicating with the consumer binary.