fix: close producer on exit

germanramos · Jun 2, 2016 · f3c615c · f3c615c
1 parent a6ea1b4
commit f3c615c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/gopath/src/service/producer.go b/gopath/src/service/producer.go
@@ -65,4 +65,5 @@ func producer(kafkaService string,
 		}
 		producer.Input() <- msg
 	}
+	_ = producer.Close()
 }