consumer

Documentation

Index

• func GetConfig() *cluster.Config
• type FinderKafkaConsumer
  • func NewFinderKafkaConsumer(brokers []string, groupId string, topics []string) (*FinderKafkaConsumer, error)
  • func (this *FinderKafkaConsumer) Consume(errorFunc func(error), notificationsFunc func(*cluster.Notification), ...)

Functions

func GetConfig

func GetConfig() *cluster.Config

Types

type FinderKafkaConsumer

type FinderKafkaConsumer struct {
	Consumer *cluster.Consumer

	Config *cluster.Config
	// contains filtered or unexported fields
}

func NewFinderKafkaConsumer

func NewFinderKafkaConsumer(brokers []string, groupId string, topics []string) (*FinderKafkaConsumer, error)

func (*FinderKafkaConsumer) Consume

func (this *FinderKafkaConsumer) Consume(errorFunc func(error), notificationsFunc func(*cluster.Notification), onMessage func(*sarama.ConsumerMessage))

启动消费