kq

type ConsumeErrorHandler func(msg kafka.Message, err error)

type ConsumeHandle func(key, value string) error

type ConsumeHandler interface {
	Consume(key, value string) error
}

type KqConf struct {
	service.ServiceConf
	Brokers     []string
	Group       string
	Topic       string
	Offset      string `json:",options=first|last,default=last"`
	Conns       int    `json:",default=1"`
	Consumers   int    `json:",default=8"`
	Processors  int    `json:",default=8"`
	MinBytes    int    `json:",default=10240"`    // 10K
	MaxBytes    int    `json:",default=10485760"` // 10M
	Username    string `json:",optional"`
	Password    string `json:",optional"`
	ForceCommit bool   `json:",default=true"`
	Mechanism   string `json:",optional"`
}

type PushOption func(options *chunkOptions)

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

type QueueOption func(*queueOptions)