kafka

package

v0.22.0 Latest Latest Go to latest Published: May 27, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

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

AsyncProducer defines a async Kafka producer.

func NewAsyncProducer(brokers []string, oo ...OptionFunc) (*AsyncProducer, error)

NewAsyncProducer creates a new async producer with default configuration.

func (ap *AsyncProducer) Close() error

Close gracefully the producer.

func (ap *AsyncProducer) Error() <-chan error

Error returns a chanel to monitor for errors.

func (ap *AsyncProducer) Send(ctx context.Context, msg *Message) error

Send a message to a topic.

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

Message abstraction of a Kafka message.

func NewJSONMessage(t string, d interface{}) (*Message, error)

NewJSONMessage creates a new message with a JSON encoded body.

func NewMessage(t string, b []byte) *Message

NewMessage creates a new message.

type OptionFunc func(*AsyncProducer) error

OptionFunc definition for configuring the async producer in a functional way.

func Timeouts(dial time.Duration) OptionFunc

Timeouts option for setting the timeouts.

func Version(version string) OptionFunc

Version option for setting the version.

type Producer interface {
	Send(ctx context.Context, msg *Message) error
	Error() <-chan error
	Close() error
}

Producer interface for Kafka.