From 3f888cdb2d1c273ae44083cd875c4fc4478d42d3 Mon Sep 17 00:00:00 2001
From: daniel <daniel.haeuser@energymeteo.de>
Date: Mon, 10 Sep 2018 14:37:26 +0200
Subject: [PATCH] Upgrade sarama to support Kafka 2.0.0 (#440)

* Upgrade Shopify/sarama to 1.18.0
---
 Gopkg.toml                      | 2 +-
 core/internal/helpers/sarama.go | 2 ++
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/Gopkg.toml b/Gopkg.toml
index 474ef1e3..34e16615 100644
--- a/Gopkg.toml
+++ b/Gopkg.toml
@@ -1,6 +1,6 @@
 [[constraint]]
   name = "github.com/Shopify/sarama"
-  version = "1.17.0"
+  version = "1.18.0"
 
 [[constraint]]
   name = "go.uber.org/zap"
diff --git a/core/internal/helpers/sarama.go b/core/internal/helpers/sarama.go
index 4b616eeb..21548e1f 100644
--- a/core/internal/helpers/sarama.go
+++ b/core/internal/helpers/sarama.go
@@ -46,6 +46,8 @@ func parseKafkaVersion(kafkaVersion string) sarama.KafkaVersion {
 		return sarama.V1_0_0_0
 	case "1.1.0":
 		return sarama.V1_1_0_0
+	case "2.0.0":
+		return sarama.V2_0_0_0
 	default:
 		panic("Unknown Kafka Version: " + kafkaVersion)
 	}