sarama

Documentation

Index

• type KafkaProducer
  • func NewKafkaProducer(opt saramaConf.KafkaOption) (*KafkaProducer, error)
  • func (p *KafkaProducer) Close() error
  • func (p *KafkaProducer) Send(topic, content string) error
  • func (p *KafkaProducer) SendN(topic string, contents []string) error

Types

type KafkaProducer

type KafkaProducer struct {
	shSarama.SyncProducer
	sync.RWMutex
}

func NewKafkaProducer

func NewKafkaProducer(opt saramaConf.KafkaOption) (*KafkaProducer, error)

func (*KafkaProducer) Close

func (p *KafkaProducer) Close() error

func (*KafkaProducer) Send

func (p *KafkaProducer) Send(topic, content string) error

func (*KafkaProducer) SendN

func (p *KafkaProducer) SendN(topic string, contents []string) error