consumer

type Consumer struct {
	Client          sarama.Client
	Topic           string
	Partitions      map[int32]bool  // which partitions to consume
	TMax            *time.Time      // abort consumption if a message later than this is received
	BeyondHighWater bool            // if set, wait for new messages. otherwise, consumption stops when last message (acc to high wtr) is received.
	StartOffset     map[int32]int64 // start offset per partition
}

type ConsumerOption func(*Consumer) error