From 7ffb7686c2deec2eb49b6e4edeff64244bd97dc9 Mon Sep 17 00:00:00 2001
From: Nicolas Reboul <nicolas.reboul31@gmail.com>
Date: Tue, 3 Jul 2018 14:27:01 +0200
Subject: [PATCH] fix #333 : regression bug introduced by sarama library

---
 pkg/endpoint/kafka.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/pkg/endpoint/kafka.go b/pkg/endpoint/kafka.go
index 7c1ce596..e450fe0d 100644
--- a/pkg/endpoint/kafka.go
+++ b/pkg/endpoint/kafka.go
@@ -60,6 +60,9 @@ func (conn *KafkaConn) Send(msg string) error {
 		cfg.Net.DialTimeout = time.Second
 		cfg.Net.ReadTimeout = time.Second * 5
 		cfg.Net.WriteTimeout = time.Second * 5
+		// Fix #333 : fix backward incompatibility introduced by sarama library
+		cfg.Producer.Return.Successes = true
+
 		c, err := sarama.NewSyncProducer([]string{uri}, cfg)
 		if err != nil {
 			return err