consumer

Documentation

Index

• type Callback
• type Config
• type Consumer
  • func New(cfg Config) (*Consumer, error)
  • func (c *Consumer) Cleanup(_ sarama.ConsumerGroupSession) error
  • func (c *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (c *Consumer) Setup(_ sarama.ConsumerGroupSession) error

Types

type Callback

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

type Config

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

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

func New

func New(cfg Config) (*Consumer, error)

func (*Consumer) Cleanup

func (c *Consumer) Cleanup(_ sarama.ConsumerGroupSession) error

Cleanup is run at the end of a session, once all ConsumeClaim goroutines have exited

func (*Consumer) ConsumeClaim

func (c *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

ConsumeClaim must start a consumer loop of ConsumerGroupClaim's Messages().

func (*Consumer) Setup

func (c *Consumer) Setup(_ sarama.ConsumerGroupSession) error

Setup is run at the beginning of a new session, before ConsumeClaim