consumer

type Callback func(message *sarama.ConsumerMessage, logger *log.Entry) (retry bool, err error)

type Config struct {
	Brokers           []string
	Callback          Callback
	GroupID           string
	MaxProcessingTime time.Duration
	Logger            *log.Logger
	RetryInterval     time.Duration
	TlsConfig         *tls.Config
	Topic             string
}

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