consumer

Documentation

Index

• 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 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)