consumer

Documentation

Index

• func NewKafkaConsumers(topic, group string, brokers []string, number uint32) map[string]*Consumer
• type Consumer
  • func (c *Consumer) Listen(deal DealHandler)
• type DealHandler
• type Process

Functions

func NewKafkaConsumers

func NewKafkaConsumers(topic, group string, brokers []string, number uint32) map[string]*Consumer

Types

type Consumer

type Consumer struct {
	*cluster.Consumer
}

func (*Consumer) Listen

func (c *Consumer) Listen(deal DealHandler)

type DealHandler

type DealHandler func(msg *sarama.ConsumerMessage) error

type Process

type Process interface {
	Deal(msg *sarama.ConsumerMessage) error
}