easykafka

Nov 28, 2023

Changes in this version

+ type AckFunc func(*sarama.ProducerMessage)

+ type ErrFunc func(*sarama.ProducerError)

type Producer

+ func (p *Producer) GetAsyncProducer() sarama.AsyncProducer

+ func (p *Producer) SetError(errFunc ErrFunc)

+ func (p *Producer) SetSuccess(ackFunc AckFunc)

Jun 8, 2021

Changes in this version

+ var ErrGroupNotFound = errors.New("group not found")

type Consumer

+ Topics []string

+ func (c *Consumer) Group() string

Jun 7, 2021

Changes in this version

type Consumer

+ Reconnect time.Duration

+ func (c *Consumer) DeleteGroup() error

type Producer

+ func (p *Producer) PublishRawMsg(msg *sarama.ProducerMessage) error

Apr 13, 2021

Changes in this version

+ var ErrAlreadyClosed = errors.New("producer already closed")

+ type Codec interface

+ Marshal func(interface{}) ([]byte, error)

+ var DefaultCodec Codec = jsonCodec{}

+ type ConsumHandler struct

+ func (h *ConsumHandler) Cleanup(sarama.ConsumerGroupSession) error

+ func (h *ConsumHandler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

+ func (h *ConsumHandler) Setup(sarama.ConsumerGroupSession) error

+ type Consumer struct

+ func NewConsumer(hosts, topics []string, groupName string, options ...Option) (*Consumer, error)

+ func (c *Consumer) Close()

+ func (c *Consumer) Run()

+ func (c *Consumer) SetHandler(h sarama.ConsumerGroupHandler)

+ type Option func(*sarama.Config)

+ type Producer struct

+ func NewProducer(hosts []string, options ...Option) (*Producer, error)

+ func (p *Producer) Close() error

+ func (p *Producer) Publish(topic string, data interface{}) error

+ func (p *Producer) PublishRaw(msg *sarama.ProducerMessage) error

+ func (p *Producer) PublishString(topic, message string) error

+ func (p *Producer) SetCodec(codec Codec)