proxy.golang.org : github.com/mistsys/go_kafka_client
Primary differences include workers concept enforcing at least once processing before committing offsets, improved rebalancing algorithm - closing obsolete connections and opening new connections without stopping the whole consumer, graceful shutdown support notifying client when it is over, batch processing, static partitions configuration support allowing to start a consumer with a predefined set of partitions never caring about rebalancing.
Registry
-
Source
- Documentation
- JSON
purl: pkg:golang/github.com/mistsys/go_kafka_client
License: Apache-2.0
Latest release: over 8 years ago
First release: over 8 years ago
Namespace: github.com/mistsys
Stars: 0 on GitHub
Forks: 1 on GitHub
See more repository details: repos.ecosyste.ms
Last synced: about 1 month ago