From f4f35f25efb726613f4906912605dcd53fd04d50 Mon Sep 17 00:00:00 2001 From: Karolis Pocius Date: Mon, 4 Dec 2017 17:12:05 +0200 Subject: [PATCH] Add support for Kafka 0.11, leaving 0.10.2 as default --- core/internal/helpers/sarama.go | 2 ++ 1 file changed, 2 insertions(+) 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) }