kafka

Documentation

Index

• func NewKafkaQueue(name string) (*kafkaQueue, error)
• type ConnParams
• type KConsumerMsg
• type MsgCb

Functions

func NewKafkaQueue

func NewKafkaQueue(name string) (*kafkaQueue, error)

Types

type ConnParams

type ConnParams struct {
	Addr     string // separate by "," for more than one servers case, such as kafka brokers
	NeedPub  bool   // for pub
	NeedSub  bool   // for sub
	AutoAck  bool   // for sub
	Exchange string
}

type KConsumerMsg

type KConsumerMsg interface {
	GetBody() []byte
	GetID() string
	Ack() error
}

type MsgCb

type MsgCb func(m KConsumerMsg) error