Method Close

pushgw/kafka/producer.go:125–128

()

}

func (p *SyncProducerWrapper) Close() error {
	close(p.stop)
	return p.syncProducer.Close()
}