producer

Documentation

Index

• type KafkaProducer
  • func NewKafkaProducer() *KafkaProducer
  • func (k *KafkaProducer) Producer(topic string, message string, num int64, f fn)
• type ProducerProvider
  • func (p *ProducerProvider) Borrow() (producer sarama.AsyncProducer)
  • func (p *ProducerProvider) Release(producer sarama.AsyncProducer)

Types

type KafkaProducer

type KafkaProducer struct {
	Version     string
	Brokers     string
	Producers   int
	KeepRunning bool
}

func NewKafkaProducer

func NewKafkaProducer() *KafkaProducer

func (*KafkaProducer) Producer

func (k *KafkaProducer) Producer(topic string, message string, num int64, f fn)

type ProducerProvider

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

pool of producers that ensure transactional-id is unique.

func (*ProducerProvider) Borrow

func (p *ProducerProvider) Borrow() (producer sarama.AsyncProducer)

func (*ProducerProvider) Release

func (p *ProducerProvider) Release(producer sarama.AsyncProducer)