consumer

type Config interface {
	ConsumerGroup() string
	InitialOffset() int64
	ProcessingTimeout() time.Duration
	ZookeeperURL() string
	ZookeeperChroot() string
	Topics() []string
}

type Consumer interface {
	Start() chan Message
	Commit(to Message) error
}

type DefaultConsumerConfig struct {
	// contains filtered or unexported fields
}

type Message interface {
	Key() []byte
	Value() []byte
	Partition() int32
	Offset() int64
}