This library provides an opinionated set of functions for reading Kafka records using segmentio/kafka-go.
We use Segment's Reader abstraction to form a consumer group,
which ensures that only one Kubernetes pod per service consumes a message.
AlpacaLabs/go-kafka
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
An opinionated set of functions for reading Kafka records.
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published