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.