producer

package
v1.14.0 Latest Latest
Warning

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

Go to latest
Published: Sep 2, 2019 License: Apache-2.0 Imports: 2 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
	ProtocolVersion string
	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