From 3cd74bb9fb69e6bee412c837eae94bef4087dcaf Mon Sep 17 00:00:00 2001 From: Vlad Gorodetsky Date: Wed, 13 Dec 2017 12:06:25 +0200 Subject: [PATCH] Update sarama to support Kafka 1.0.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 4dcdc384..e9022af1 100644 --- a/Gopkg.toml +++ b/Gopkg.toml @@ -1,6 +1,6 @@ [[constraint]] name = "github.com/Shopify/sarama" - version = "1.14.0" + version = "1.15.0" [[constraint]] name = "go.uber.org/zap" diff --git a/core/internal/helpers/sarama.go b/core/internal/helpers/sarama.go index f73d6dde..492d7b0a 100644 --- a/core/internal/helpers/sarama.go +++ b/core/internal/helpers/sarama.go @@ -42,6 +42,8 @@ func parseKafkaVersion(kafkaVersion string) sarama.KafkaVersion { return sarama.V0_10_2_0 case "0.11.0", "0.11.0.1", "0.11.0.2": return sarama.V0_11_0_0 + case "1.0.0": + return sarama.V1_0_0_0 default: panic("Unknown Kafka Version: " + kafkaVersion) }