kafka

Documentation

Index

• type Interface
• type Message
• type Producer
  • func New(brokers []string, topic string, tlsConfig *tls.Config, logger *log.Logger) (*Producer, error)
  • func (p *Producer) Produce(msg Message) (offset int64, err error)

Types

type Interface

type Interface interface {
	Produce(msg Message) (int64, error)
}

type Message

type Message []byte

type Producer

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

func New

func New(brokers []string, topic string, tlsConfig *tls.Config, logger *log.Logger) (*Producer, error)

func (*Producer) Produce

func (p *Producer) Produce(msg Message) (offset int64, err error)