producer

package
v1.17.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 24, 2020 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL