kafkaclient

README

kafkaclient

Documentation

Index

• func ConsumerMsg(broders []string, topic string, groupid string, clientid string, ...)
• func ProducerMsg(broders []string, topic string, clientid string, MSG *chan []byte)
• type MyConsumerGroupHandler
  • func (h *MyConsumerGroupHandler) Cleanup(sarama.ConsumerGroupSession) error
  • func (h *MyConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (h *MyConsumerGroupHandler) Setup(sarama.ConsumerGroupSession) error

Functions

func ConsumerMsg

func ConsumerMsg(broders []string, topic string, groupid string, clientid string, MSG *chan []byte)

消费者

func ProducerMsg

func ProducerMsg(broders []string, topic string, clientid string, MSG *chan []byte)

生产者

Types

type MyConsumerGroupHandler

type MyConsumerGroupHandler struct {
	Msg *chan []byte
}

MyConsumerGroupHandler 是 ConsumerGroupHandler 接口的实现

func (*MyConsumerGroupHandler) Cleanup

func (h *MyConsumerGroupHandler) Cleanup(sarama.ConsumerGroupSession) error

Cleanup 执行会话结束后的清理操作

func (*MyConsumerGroupHandler) ConsumeClaim

func (h *MyConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

ConsumeClaim 处理分配给消费者的消息

func (*MyConsumerGroupHandler) Setup

func (h *MyConsumerGroupHandler) Setup(sarama.ConsumerGroupSession) error

Setup 执行会话开始前的初始化操作