producer

Documentation

Index

• type IProducer
• type Producer
  • func New(topic string, brokers []string, maxRetry int) (*Producer, error)
  • func (p *Producer) Close() error
  • func (p *Producer) SendMessage(message string) (partition int32, offset int64, err error)

Types

type IProducer

type IProducer interface {
	SendMessage(message string) (partition int32, offset int64, err error)
	Close() error
}

type Producer

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

func New

func New(topic string, brokers []string, maxRetry int) (*Producer, error)

func (*Producer) Close

func (p *Producer) Close() error

func (*Producer) SendMessage

func (p *Producer) SendMessage(message string) (partition int32, offset int64, err error)