kafka

Documentation

Index

• func InitConsumer(handler sarama.ConsumerGroupHandler, url, topic string) error
• func InitProducer(url, topic string) (err error)
• type Producer
  • func NewProducer(url, topic string) (*Producer, error)
  • func (p *Producer) SendMessage(c context.Context, key string, msg proto.Message) (int32, int64, error)

Functions

func InitConsumer

func InitConsumer(handler sarama.ConsumerGroupHandler, url, topic string) error

func InitProducer

func InitProducer(url, topic string) (err error)

Types

type Producer

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

var ProducerClient *Producer

func NewProducer

func NewProducer(url, topic string) (*Producer, error)

func (*Producer) SendMessage

func (p *Producer) SendMessage(c context.Context, key string, msg proto.Message) (int32, int64, error)