sync

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

type GroupHandler interface {
	Setup(sarama.ConsumerGroupSession) error
	Cleanup(sarama.ConsumerGroupSession) error
	ConsumeClaim(sarama.ConsumerGroupSession, sarama.ConsumerGroupClaim) error
}

type Option func(s *Service) error

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