kafka

Documentation

Index

• func NewReader(cfg kafka.ReaderConfig, log logger.Logger) *kafka.Reader
• func NewWriter(writer kafka.Writer, config WriterConfig) *kafka.Writer
• type Reader
• type WriterConfig

Functions

func NewReader

func NewReader(cfg kafka.ReaderConfig, log logger.Logger) *kafka.Reader

func NewWriter

func NewWriter(writer kafka.Writer, config WriterConfig) *kafka.Writer

Types

type Reader

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

type WriterConfig

type WriterConfig struct {
	Brokers     []string
	Compression compress.Compression
	Logger      logger.Logger
	Balancer    kafka.Balancer
}