luciano/amazon-kinesis-client-go
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions
Amazon Kinesis Client for Go
187 commits 11 branches 1 tag 8.2 MiB
Go 94.4%
Makefile 5.6%
Find a file
dependabot-preview[bot] 54f91f4073
Bump github.com/stretchr/testify from 1.6.1 to 1.7.0 
Bumps [github.com/stretchr/testify](https://github.com/stretchr/testify) from 1.6.1 to 1.7.0.
- [Release notes](https://github.com/stretchr/testify/releases)
- [Commits](https://github.com/stretchr/testify/compare/v1.6.1...v1.7.0)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>
2021-01-13 18:18:37 +00:00
.circleci Upgrade go to v1.13 2019-10-18 09:45:22 -07:00
.github add codeowners 2020-07-20 18:11:27 +00:00
batchconsumer Refactor zlib decompression into the splitter package 2020-11-12 11:37:13 -05: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
golang.mk upgrade kayvee-go to 6.24.0 2020-08-14 16:30:08 -07:00
Gopkg.lock Bump github.com/stretchr/testify from 1.6.1 to 1.7.0 2021-01-13 18:18:37 +00:00
Gopkg.toml Add functionality for handling KPL aggregates and zlib 2020-11-16 11:01:28 -05:00
Makefile update to repo1 link for jars 2020-04-06 13:31:10 -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.