kafka

Documentation

Index

• Constants
• func InitKafka()
• type Consumer
  • func GetConsumer(key string) Consumer
• type ConsumerErrorHandler
• type ConsumerMessageHandler
• type Producer
  • func GetProducer(key string) Producer
• type ProducerErrorHandler
• type ProducerMessageHandler

Constants

const (
	ACK_BEFORE_AUTO    = 0
	ACK_AFTER_NOERROR  = 1
	ACK_AFTER_NOMATTER = 2
)

Functions

func InitKafka

func InitKafka()

Types

type Consumer

type Consumer interface {
	Close() error
	Consume(topics string, mh ConsumerMessageHandler, eh ConsumerErrorHandler) error
	ConsumeM(topics []string, mh ConsumerMessageHandler, eh ConsumerErrorHandler) error
}

func GetConsumer

func GetConsumer(key string) Consumer

type ConsumerErrorHandler

type ConsumerErrorHandler func(err error)

type ConsumerMessageHandler

type ConsumerMessageHandler func(msg *sarama.ConsumerMessage) error

type Producer

type Producer interface {
	Close() error
	Produce(msgs ...*sarama.ProducerMessage) error
	AsyncHandle(mh ProducerMessageHandler, eh ProducerErrorHandler) // 必须设置 asyncReturnSuccess 或 asyncReturnError
}

func GetProducer

func GetProducer(key string) Producer

type ProducerErrorHandler

type ProducerErrorHandler func(err *sarama.ProducerError)

type ProducerMessageHandler

type ProducerMessageHandler func(msg *sarama.ProducerMessage)