go-consumergroup是一款提供集群功能的kafka客户端,支持 rebalance,offset 自动或者手动管理以及 chroot 功能。
https://github.com/samuel/go-zookeeper
https://github.com/Shopify/sarama
$ make test
***NOTE: *** 跑测试用例需要预先安装 docker-compose
go-consumergroup是一款提供集群功能的kafka客户端,支持 rebalance,offset 自动或者手动管理以及 chroot 功能。
https://github.com/samuel/go-zookeeper
https://github.com/Shopify/sarama
$ make test
***NOTE: *** 跑测试用例需要预先安装 docker-compose