Update sarama to support Kafka 1.0.0 (#306)

linkedin · Dec 14, 2017 · e3a1493 · e3a1493
1 parent 946a425
commit e3a1493
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git 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
@@ -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)
 	}