luciano/amazon-kinesis-client-go
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions
Amazon Kinesis Client for Go
122 commits 11 branches 1 tag 8.2 MiB
Go 94.4%
Makefile 5.6%
Find a file
Xavi 42fba675bb
Merge pull request #31 from Clever/fix-type-o 
Fixed type-o: guage -> gauge
2018-10-05 15:38:04 -07:00
.circleci [INFRA-3186] autotranslate CircleCI 1.0 -> 2.0 2018-08-17 15:21:41 -07:00
batchconsumer Added Initialize method to sender 2018-08-09 16:43:30 -07:00
cmd Added Initialize method to sender 2018-08-09 16:43:30 -07:00
decode Fixed type-o: guage -> gauge 2018-10-05 15:31:48 -07:00
kcl Cleaned up shutdown code 2017-09-20 21:28:43 +00:00
splitter fix lambda -> rsyslog message conversion to always have a task ID 2018-03-13 16:48:41 +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
consumer.properties initial commit 2017-02-08 20:23:00 +00:00
golang.mk Updated golang.mk to v0.3.8 2018-08-09 16:32:10 -07:00
Gopkg.lock Remove self-references in Gopkg.toml 2018-02-16 13:14:07 -08:00
Gopkg.toml Remove self-references in Gopkg.toml 2018-02-16 13:14:07 -08:00
Makefile golang upgrade 2018-05-18 15:54:07 -07:00
README.md initial commit 2017-02-08 20:23:00 +00:00

README.md

amazon-kinesis-client-go

A port of amazon-kinesis-client-python to 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.