From f3c615c6e7f33b8ece9421885235d1c9044e78c4 Mon Sep 17 00:00:00 2001
From: German Ramos Garcia <german.ramos.garcia@bbva.com>
Date: Thu, 2 Jun 2016 16:11:45 +0200
Subject: [PATCH] fix: close producer on exit

---
 gopath/src/service/producer.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/gopath/src/service/producer.go b/gopath/src/service/producer.go
index aae95e1..7a12f89 100644
--- 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()
 }