// NewProducer create new kafka producer
NewProducer create new kafka producer
// NewProducer create new kafka producer
func NewProducer(log logger.Logger, brokers []string) *producer {
	return &producer{
		log:     log,
		brokers: brokers,
		w:       NewWriter(brokers, kafka.LoggerFunc(log.Errorf)),
	}
}
func NewProducer ( log logger . Logger , brokers [ ] string ) * producer { return & producer { log : log , brokers : brokers , w : NewWriter ( brokers , kafka . LoggerFunc ( log . Errorf ) ) , } }
NewProducer create new kafka producer
NewProducer create new kafka producer