kafkaProducer

type Writer struct {
	Client *kafka.Writer
}

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