consumer

Documentation

Index

• type Consumer
  • func New(opts Options) (c Consumer, err error)
• type Options
• type Response

Types

type Consumer

type Consumer interface {
	Run(chResponse chan Response)
	Close() error
}

func New

func New(opts Options) (c Consumer, err error)

type Options

type Options struct {
	Configs            map[string]interface{}
	Topics             []string
	ReadMessageTimeout time.Duration
	ReadMessageDelay   time.Duration
}

type Response

type Response struct {
	Error   error
	Message *kafkamod.Message
}