Amazon Kinesis Client for Go
Find a file
2024-09-19 07:23:19 -07:00
.circleci Update github known hosts key 2023-04-25 14:56:16 -04:00
.github notify CI failure 2024-09-18 13:04:48 -04:00
batchconsumer Refactor zlib decompression into the splitter package 2020-11-12 11:37:13 -05:00
bin dep -> go modules 2021-06-03 15:41:20 -07:00
cmd Merge pull request #33 from wwwjfy/fix-shutdown-requested 2018-12-11 16:28:37 -08:00
decode Add decoding of JSON logs in Fluent format. 2020-08-17 15:02:59 -07:00
kcl Merge pull request #33 from wwwjfy/fix-shutdown-requested 2018-12-11 16:28:37 -08:00
splitter Simplify main function's name. 2020-11-16 17:37:53 -05: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
go.mod dep -> go modules 2021-06-03 15:41:20 -07:00
go.sum dep -> go modules 2021-06-03 15:41:20 -07:00
golang.mk dep -> go modules 2021-06-03 15:41:20 -07:00
Makefile dep -> go modules 2021-06-03 15:41:20 -07:00
README.md initial commit 2017-02-08 20:23:00 +00:00
VERSION add versioning 2021-03-04 10:11:51 -08:00

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.