kafka

Documentation

Index

• func NewReader(cfg kafka.ReaderConfig, log logger.Logger) *kafka.Reader
• func NewWriter(writer kafka.Writer, log logger.Logger) *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, log logger.Logger) *kafka.Writer

Types

type Reader

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

type WriterConfig

type WriterConfig struct {
	Logger logger.Logger
}