Merge pull request #215 from heltonmarx/cleanup_producer

Remove unused channels
lovoo · Jan 6, 2020 · 2d7e458 · 2d7e458
2 parents 1cf2c41 + 73438ef
commit 2d7e458
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/kafka/producer.go b/kafka/producer.go
@@ -17,8 +17,6 @@ type Producer interface {
 
 type producer struct {
 	producer sarama.AsyncProducer
-	stop     chan bool
-	done     chan bool
 	wg       sync.WaitGroup
 }
 
@@ -31,8 +29,6 @@ func NewProducer(brokers []string, config *sarama.Config) (Producer, error) {
 
 	p := producer{
 		producer: aprod,
-		stop:     make(chan bool),
-		done:     make(chan bool),
 	}
 
 	p.run()