go-consumergroup

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

• go-zookeeper
• sarama
• zk_wrapper

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