consumer

Documentation

Index

• func NewKafkaConfig() *sarama.Config
• type ConsumerGroupHandler
  • func (h ConsumerGroupHandler) Cleanup(s sarama.ConsumerGroupSession) error
  • func (h ConsumerGroupHandler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (h ConsumerGroupHandler) Setup(s sarama.ConsumerGroupSession) error

Functions

func NewKafkaConfig

func NewKafkaConfig() *sarama.Config

创建kafka配置

Types

type ConsumerGroupHandler

type ConsumerGroupHandler struct {
}

消费者组处理器

func (ConsumerGroupHandler) Cleanup

func (h ConsumerGroupHandler) Cleanup(s sarama.ConsumerGroupSession) error

func (ConsumerGroupHandler) ConsumeClaim

func (h ConsumerGroupHandler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (ConsumerGroupHandler) Setup

func (h ConsumerGroupHandler) Setup(s sarama.ConsumerGroupSession) error