func (p *producerImp) Close() {
	if err := p.saramaProducer.Close(); err != nil {
		log.Errorln(err)
	}
}
// Close can be used to cleanly shut down the producer
Close can be used to cleanly shut down the producer
// Close can be used to cleanly shut down the producer
func (p *producerImp) Close() {
	if err := p.saramaProducer.Close(); err != nil {
		log.Errorln(err)
	}
}
func ( p * producerImp ) Close ( ) { if err := p . saramaProducer . Close ( ) ; err != nil { log . Errorln ( err ) } }
Close can be used to cleanly shut down the producer
Close can be used to cleanly shut down the producer