go-kinesis

Batch producer for AWS Kinesis built on the official Go SDK.

by tj

Star on GitHub Fork

22 stars 13 forks 3 contributorsQuiet · 7y agoSince 2015MIT

Meet the team

See all 3 on GitHub →

tj9 contributions

harlow3 contributions

bnoon1 contribution

Languages

View on GitHub →

Go100%

Commit activity

Last 12 weeks · 0 commits

Full graph →

Community health

2 of 6 standards met

Community profile →

✓README✓License○Contributing○Code of Conduct○Issue Template○PR Template

Recent PRs & issues

Quiet · 5 discussions · Last activity 7y ago

See all on GitHub →

Allow override of AWS region in KinesisOpenIssue

Should be able to override the AWS region in the config. Example:

mjcbsn22 · 7y ago

MaxAttempts and error handlerOpenIssue

Add MaxAttempts and offload to an error handler if things are really backed up. This is a critical state for most applications but beats dropping them on the floor.

tj · 8y ago

Firehose supportOpenIssue

@mattaitchison has a working solution here: https://github.com/mattaitchison/go-kinesis/commit/1dac613856f29af88e91410b2a00774bb74dd0c3 It might be worth adding a PR to connect it here.

jadbox · 8y ago

Recent fixes

View closed PRs →

Allow for overiding the AWS region for KinesisMergedPR

Fixes #11

mjcbsn22 · 4y ago

Flush the buffered records when Stop()'dMergedPR

bnoon · 8y ago

Flush if next record would make the request size too bigMergedPR

Fixes https://github.com/tj/go-kinesis/issues/3 as an error is already thrown when we try to add a record which is max than the max record size.

phacops · 8y ago

Structured data for AI agents

Repository: tj/go-kinesis. Description: Batch producer for AWS Kinesis built on the official Go SDK. Stars: 22, Forks: 13. Primary language: Go. Languages: Go (100%). License: MIT. Open PRs: 0, open issues: 5. Last activity: 7y ago. Community health: 42%. Top contributors: tj, harlow, bnoon.