kafka

Documentation

Index

• type Broker
  • func NewBroker(brokers []string, config *sarama.Config) (*Broker, error)
  • func (b Broker) Send(event outbox.Message) error

Types

type Broker

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

Broker implements the MessageBroker interface

func NewBroker

func NewBroker(brokers []string, config *sarama.Config) (*Broker, error)

NewBroker constructor

func (Broker) Send

func (b Broker) Send(event outbox.Message) error

Send delivers the message to kafka