consumer

type BatchConsumerConfig struct {
	BufferCapacity        int // msg capacity
	MaxBufSize            int // max message size
	TickerIntervalSeconds int
	Callback              func([]*ConsumerSessionMessage) error
}

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

type ConsumerGroupHandler interface {
	sarama.ConsumerGroupHandler
	WaitReady()
	Reset()
}

type ConsumerSessionMessage struct {
	Session sarama.ConsumerGroupSession
	Message *sarama.ConsumerMessage
}

type MultiAsyncConsumerConfig struct {
	BufChan chan *ConsumerSessionMessage
}

type MultiBatchConsumerConfig struct {
	BufferCapacity        int // msg capacity
	MaxBufSize            int // max message size
	TickerIntervalSeconds int

	BufChan chan batchMessages
}