From 3a4372f5c80ee8426dc85cf3edd1cea735dba119 Mon Sep 17 00:00:00 2001 From: Karolis Date: Mon, 4 Dec 2017 17:21:29 +0200 Subject: [PATCH] Upgrade sarama dependency to support Kafka 0.11.0 (#297) * Update Shopify/sarama to 1.14.0 * Add support for Kafka 0.11, leaving 0.10.2 as default --- 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 4458919e..4dcdc384 100644 --- a/Gopkg.toml +++ b/Gopkg.toml @@ -1,6 +1,6 @@ [[constraint]] name = "github.com/Shopify/sarama" - version = "1.12.0" + version = "1.14.0" [[constraint]] name = "go.uber.org/zap" diff --git a/core/internal/helpers/sarama.go b/core/internal/helpers/sarama.go index d329f631..f73d6dde 100644 --- a/core/internal/helpers/sarama.go +++ b/core/internal/helpers/sarama.go @@ -40,6 +40,8 @@ func parseKafkaVersion(kafkaVersion string) sarama.KafkaVersion { return sarama.V0_10_1_0 case "", "0.10.2", "0.10.2.0": return sarama.V0_10_2_0 + case "0.11.0", "0.11.0.1", "0.11.0.2": + return sarama.V0_11_0_0 default: panic("Unknown Kafka Version: " + kafkaVersion) }