consumer

Documentation

Index

• func RunConsumer(ctx context.Context, zk string, groupid string, topic string, debug bool, ...) (err error)
• func Start(ctx context.Context, config util.Config, control interfaces.Controller, ...) (err error)
• type Consumer

Functions

func RunConsumer

func RunConsumer(ctx context.Context, zk string, groupid string, topic string, debug bool, listener func(topic string, msg []byte) error, errorhandler func(err error)) (err error)

func Start

func Start(ctx context.Context, config util.Config, control interfaces.Controller, runtimeErrorHandler func(err error)) (err error)

Types

type Consumer

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