Skip to content

A simple wrapper for the Sarama high-level Apache Kafka consumer and producer in Golang

License

Notifications You must be signed in to change notification settings

Cuebiq/sarama-easy

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

4 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

sarama-easy

Sarama is a Golang client for Apache Kafka. This is a light wrapper and example demo for Sarama's async producer and consumer (including auto-rebalancing consumer groups.)

Usage

Run the demo producer/consumer

# From the root dir of the repo checkout:
script/build

docker-compose up

# From another terminal session:
bin/consumer-example &

bin/producer-example

Result

  • Producer will emit 10 messages and a sentinel value to the example topic, then shut down.
  • Consumer will receive 10 example messages, and a sentinel message triggering it's own shutdown.

About

A simple wrapper for the Sarama high-level Apache Kafka consumer and producer in Golang

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Languages

  • Go 98.9%
  • Other 1.1%