producer

Documentation

Index

• func InitKafkaProducer()
• func NewProducerConfiguration() *sarama.Config
• type SimAsyncProducer
  • func NewSimAsyncProducer() (producer *SimAsyncProducer, err error)
  • func (sap *SimAsyncProducer) Start()
  • func (sap *SimAsyncProducer) Stop()

Functions

func InitKafkaProducer

func InitKafkaProducer()

func NewProducerConfiguration

func NewProducerConfiguration() *sarama.Config

Types

type SimAsyncProducer

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

func NewSimAsyncProducer

func NewSimAsyncProducer() (producer *SimAsyncProducer, err error)

func (*SimAsyncProducer) Start

func (sap *SimAsyncProducer) Start()

func (*SimAsyncProducer) Stop

func (sap *SimAsyncProducer) Stop()