kafka

Documentation

Index

• type AsyncProducer
  • func NewAsyncProducer(brokers []string, oo ...OptionFunc) (*AsyncProducer, error)
  • func (ap *AsyncProducer) Close() error
  • func (ap *AsyncProducer) Error() <-chan error
  • func (ap *AsyncProducer) Send(ctx context.Context, msg *Message) error
• type Message
  • func NewJSONMessage(t string, d interface{}) (*Message, error)
  • func NewMessage(t string, b []byte) *Message
• type OptionFunc
  • func Timeouts(dial time.Duration) OptionFunc
  • func Version(version string) OptionFunc
• type Producer

Types

type AsyncProducer

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

AsyncProducer defines a async Kafka producer.

func NewAsyncProducer

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

NewAsyncProducer creates a new async producer with default configuration.

func (*AsyncProducer) Close

func (ap *AsyncProducer) Close() error

Close gracefully the producer.

func (*AsyncProducer) Error

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

Error returns a chanel to monitor for errors.

func (*AsyncProducer) Send

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

Send a message to a topic.

type Message

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

Message abstraction of a Kafka message.

func NewJSONMessage

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

NewJSONMessage creates a new message with a JSON encoded body.

func NewMessage

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

NewMessage creates a new message.

type OptionFunc

type OptionFunc func(*AsyncProducer) error

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

func Timeouts

func Timeouts(dial time.Duration) OptionFunc

Timeouts option for setting the timeouts.

func Version

func Version(version string) OptionFunc

Version option for setting the version.

type Producer

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

Producer interface for Kafka.