Skip to content

bitleak/go-consumergroup

 
 

Repository files navigation

go-consumergroup Build Status Go Report Card

Go-consumergroup is a kafka consumer library written in golang with rebalance and chroot supports.

Chinese Doc

Requirements

  • Apache Kafka 0.8.x, 0.9.x, 0.10.x, 0.11.x, 1.0.x

Dependencies

Getting started

  • API documentation and examples are available via godoc.
  • The example directory contains more elaborate example applications.

User Defined Logger

logger := logrus.New()
cg.SetLogger(logger)

Run Tests

$ make test

NOTE: docker-compse is required to run tests

About

golang kafka consumer group

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Languages

  • Go 96.3%
  • Makefile 2.0%
  • Shell 1.7%