consumer

type Builder interface {
	NewConsumer() (Consumer, error)
}

type Configuration struct {
	auth.AuthenticationConfig
	Consumer

	Brokers         []string
	Topic           string
	GroupID         string
	ClientID        string
	ProtocolVersion string
}

type Consumer interface {
	Partitions() <-chan cluster.PartitionConsumer
	MarkPartitionOffset(topic string, partition int32, offset int64, metadata string)
	io.Closer
}