consumer

Documentation

Index

• func NewConsumerWithMultipleTopics(ctx context.Context, broker string, groupId string, topics []string, ...) error
• func Start(ctx context.Context, config config.Config, control listener.Controller) (err error)
• type Consumer
  • func NewConsumer(ctx context.Context, broker string, groupid string, topic string, ...) (consumer *Consumer, err error)

Functions

func NewConsumerWithMultipleTopics

func NewConsumerWithMultipleTopics(ctx context.Context, broker string, groupId string, topics []string, listener func(topic string, delivery []byte) error, errhandler func(topice string, err error)) error

func Start

func Start(ctx context.Context, config config.Config, control listener.Controller) (err error)

Types

type Consumer

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

func NewConsumer

func NewConsumer(ctx context.Context, broker string, groupid string, topic string, listener func(topic string, msg []byte) error, errorhandler func(err error, consumer *Consumer)) (consumer *Consumer, err error)