Versions in this module Expand all Collapse all v1 v1.7.0 Sep 19, 2018 Changes in this version + type Builder interface + NewConsumer func() (Consumer, error) + type Configuration struct + Brokers []string + GroupID string + Topic string + func (c *Configuration) NewConsumer() (Consumer, error) + type Consumer interface + MarkPartitionOffset func(topic string, partition int32, offset int64, metadata string) + Partitions func() <-chan cluster.PartitionConsumer
Go to main page