kafkamessagehandler

Documentation

Index

• type ConsumerGroupHandler
  • func NewConsumerGroupHandler() *ConsumerGroupHandler
  • func (c *ConsumerGroupHandler) Cleanup(sarama.ConsumerGroupSession) error
  • func (c *ConsumerGroupHandler) Close()
  • func (c *ConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (c *ConsumerGroupHandler) Messages() <-chan *kafkaconsumermessage.Message
  • func (c *ConsumerGroupHandler) Setup(sarama.ConsumerGroupSession) error

Types

type ConsumerGroupHandler

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

func NewConsumerGroupHandler

func NewConsumerGroupHandler() *ConsumerGroupHandler

func (*ConsumerGroupHandler) Cleanup

func (c *ConsumerGroupHandler) Cleanup(sarama.ConsumerGroupSession) error

func (*ConsumerGroupHandler) Close

func (c *ConsumerGroupHandler) Close()

func (*ConsumerGroupHandler) ConsumeClaim

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

func (*ConsumerGroupHandler) Messages

func (c *ConsumerGroupHandler) Messages() <-chan *kafkaconsumermessage.Message

func (*ConsumerGroupHandler) Setup

func (c *ConsumerGroupHandler) Setup(sarama.ConsumerGroupSession) error