Versions in this module Expand all Collapse all v0 v0.3.2 Nov 9, 2018 Changes in this version + func Init(addrs []string, group string, topics []string) error + func LoopConsume()