consumer

Documentation

Index

• type Consumer
  • func NewConsumer(brokers []string, group string, topics []string, ...) (*Consumer, error)
  • func NewConsumerDefault(scanner sarama.ConsumerGroupHandler) (*Consumer, error)
  • func (c *Consumer) Consume() error
• type GroupHandler
  • func NewConsumerGroupHandler(scanner *scanner.Scanner, logService logservice.Logger) *GroupHandler
  • func NewConsumerGroupHandlerDefault(scanner *scanner.Scanner) *GroupHandler
  • func (h *GroupHandler) Cleanup(session sarama.ConsumerGroupSession) error
  • func (h *GroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (h *GroupHandler) Setup(session sarama.ConsumerGroupSession) error
• type Scanner

Types

type Consumer

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

func NewConsumer

func NewConsumer(brokers []string, group string, topics []string, consumerHandler sarama.ConsumerGroupHandler) (*Consumer, error)

func NewConsumerDefault

func NewConsumerDefault(scanner sarama.ConsumerGroupHandler) (*Consumer, error)

func (*Consumer) Consume

func (c *Consumer) Consume() error

type GroupHandler

type GroupHandler struct {
	Log logservice.Logger
	// contains filtered or unexported fields
}

func NewConsumerGroupHandler

func NewConsumerGroupHandler(scanner *scanner.Scanner, logService logservice.Logger) *GroupHandler

func NewConsumerGroupHandlerDefault

func NewConsumerGroupHandlerDefault(scanner *scanner.Scanner) *GroupHandler

func (*GroupHandler) Cleanup

func (h *GroupHandler) Cleanup(session sarama.ConsumerGroupSession) error

func (*GroupHandler) ConsumeClaim

func (h *GroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (*GroupHandler) Setup

func (h *GroupHandler) Setup(session sarama.ConsumerGroupSession) error

type Scanner

type Scanner interface {
}