kafkaProducer

Documentation

Index

• type Writer
  • func NewKafkaWriter(cfg *WriterConfig) *Writer
• type WriterConfig

Types

type Writer

type Writer struct {
	Client *kafka.Writer
}

func NewKafkaWriter

func NewKafkaWriter(cfg *WriterConfig) *Writer

type WriterConfig

type WriterConfig struct {
	Brokers      []string
	Topic        string
	RequiredAcks kafka.RequiredAcks
}