producer

Documentation

Index

• type Config
• type DefaultProducerConfig
  • func (c DefaultProducerConfig) KafkaBrokers() []string
• type Message
  • func NewByteMessage(topic, key string, value []byte) Message
  • func NewStringMessage(topic, key, value string) Message
• type Producer
  • func New(config Config) (Producer, error)

Types

type Config

type Config interface {
	KafkaBrokers() []string
}

Config represents the configuration required for a consumer service

type DefaultProducerConfig

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

DefaultProducerConfig is a default Config implementation

func (DefaultProducerConfig) KafkaBrokers

func (c DefaultProducerConfig) KafkaBrokers() []string

KafkaBrokers implements Config.KafkaBrokers

type Message

type Message interface {
	Topic() string
	Key() sarama.Encoder
	Value() sarama.Encoder
}

Message ...

func NewByteMessage

func NewByteMessage(topic, key string, value []byte) Message

NewByteMessage returns a new Message

func NewStringMessage

func NewStringMessage(topic, key, value string) Message

NewStringMessage returns a new Message

type Producer

type Producer interface {
	Send(Message) (partition int32, offset int64, err error)
}

Producer ...

func New

func New(config Config) (Producer, error)

New ...