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.
This repository has been archived by the owner on Sep 18, 2024. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 0
AlpacaLabs/go-kafka
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