From 68e2b6d736315eb1eebf291d75f761ea094fbbfc Mon Sep 17 00:00:00 2001
From: tidwall <joshbaker77@gmail.com>
Date: Fri, 3 Jul 2020 11:57:15 -0700
Subject: [PATCH] Updated Kafka version

---
 internal/endpoint/kafka.go | 1 +
 1 file changed, 1 insertion(+)

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 {