Skip to content
golang kafka consumer group
Go Makefile Shell
Branch: master
Clone or download

go-consumergroup Build Status Go Report Card

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

Chinese Doc


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


Getting started

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

User Defined Logger

logger := logrus.New()

Run Tests

$ make test

NOTE: docker-compse is required to run tests

You can’t perform that action at this time.