Skip to content
This repository has been archived by the owner on Nov 28, 2023. It is now read-only.
/ kafka-cg Public archive
forked from funkygao/kafka-cg

Load-balancing, resuming Kafka consumer for go, backed by Zookeeper.

License

Notifications You must be signed in to change notification settings

MeltwaterArchive/kafka-cg

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

kafka

Kafka libraries, tools and example applications built on top of the sarama package.

Libraries

  • consumergroup: Distributed Kafka consumer, backed by Zookeeper, supporting load balancing and offset persistence, as defined by the Kafka documentation. API documentation can be found on godoc.org

Tools

The following tools can be useful for discovery, testing, and benchmarking. They also serve as examples of how to use Sarama.

  • tools/stressproducer: A tool to stress test the producer to measure throughput and latency.
  • tools/consoleconsumer: A tool to consume a kafka topic and write messages to STDOUT.

Examples

  • examples/consumergroup: An example consumer application that uses the consumergroup library mentioned above.

About

Load-balancing, resuming Kafka consumer for go, backed by Zookeeper.

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • Go 100.0%