config

Documentation

Index

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

Types

type Configuration

type Configuration struct {
	Brokers []string
}

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

type ProducerBuilder

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

ProducerBuilder builds a new kafka producer