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