producer

Documentation

Index

• type Builder
• type Configuration
  • func (c *Configuration) NewProducer() (sarama.AsyncProducer, error)

Types

type Builder

type Builder interface {
	NewProducer() (sarama.AsyncProducer, error)
}

Builder builds a new kafka producer

type Configuration

type Configuration struct {
	Brokers          []string
	RequiredAcks     sarama.RequiredAcks
	Compression      sarama.CompressionCodec
	CompressionLevel int
	ProtocolVersion  string
	BatchLinger      time.Duration
	BatchSize        int
	BatchMaxMessages int
	auth.AuthenticationConfig
}

Configuration describes the configuration properties needed to create a Kafka producer

func (*Configuration) NewProducer

func (c *Configuration) NewProducer() (sarama.AsyncProducer, error)

NewProducer creates a new asynchronous kafka producer