kafkago

Documentation

Index

• type Handler
  • func New(c sk.ProducerConfig, options ...OptionFunc) (*Handler, error)
  • func (h *Handler) Send(topic string, value []byte) error
  • func (h *Handler) Stop()
• type Logger
• type OptionFunc
  • func WithLogger(log Logger) OptionFunc
• type Producer
• type SimpleKafkaGoProducer
  • func (p *SimpleKafkaGoProducer) SendWithKey(topic string, key, value []byte) error
• type Writer

Types

type Handler

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

func New

func New(c sk.ProducerConfig, options ...OptionFunc) (*Handler, error)

New creates a new kafka producer

func (*Handler) Send

func (h *Handler) Send(topic string, value []byte) error

func (*Handler) Stop

func (h *Handler) Stop()

type Logger

type Logger interface {
	Infof(string, ...interface{})
	Errorf(string, ...interface{})
}

type OptionFunc

type OptionFunc func(*Handler) error

func WithLogger

func WithLogger(log Logger) OptionFunc

type Producer

type Producer interface {
	Close() error
	SendWithKey(topic string, key, value []byte) error
}

type SimpleKafkaGoProducer

type SimpleKafkaGoProducer struct {
	Writer
	// contains filtered or unexported fields
}

func (*SimpleKafkaGoProducer) SendWithKey

func (p *SimpleKafkaGoProducer) SendWithKey(topic string, key, value []byte) error

type Writer

type Writer interface {
	Close() error
	WriteMessages(ctx context.Context, msgs ...kafka.Message) error
}