worker

Documentation

Index

• func NewReader(cfg ReaderConfig) *kafka.Reader
• type Consumer
  • func (consumer *Consumer) Close()
  • func (consumer *Consumer) Start()
• type ConsumerInterface
  • func NewConsumer(config ReaderConfig) ConsumerInterface
• type ReaderConfig

Functions

func NewReader

func NewReader(cfg ReaderConfig) *kafka.Reader

Types

type Consumer

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

func (*Consumer) Close

func (consumer *Consumer) Close()

func (*Consumer) Start

func (consumer *Consumer) Start()

type ConsumerInterface

type ConsumerInterface interface {
	Start()
	Close()
}

func NewConsumer

func NewConsumer(config ReaderConfig) ConsumerInterface

type ReaderConfig

type ReaderConfig struct {
	Brokers []string
	Topic   string
	GroupID string
}