diff --git a/Gopkg.toml b/Gopkg.toml
index 034dd674..1bb4596c 100644
--- a/Gopkg.toml
+++ b/Gopkg.toml
@@ -1,6 +1,6 @@
 [[constraint]]
   name = "github.com/Shopify/sarama"
-  version = "1.21.0"
+  version = "1.22.0"
 
 [[constraint]]
   name = "go.uber.org/zap"
diff --git a/core/internal/helpers/sarama.go b/core/internal/helpers/sarama.go
index f8d6f64f..99458a10 100644
--- a/core/internal/helpers/sarama.go
+++ b/core/internal/helpers/sarama.go
@@ -48,6 +48,7 @@ var kafkaVersions = map[string]sarama.KafkaVersion{
 	"2.0.0":    sarama.V2_0_0_0,
 	"2.0.1":    sarama.V2_0_0_0,
 	"2.1.0":    sarama.V2_1_0_0,
+	"2.2.0":    sarama.V2_2_0_0,
 }
 
 func parseKafkaVersion(kafkaVersion string) sarama.KafkaVersion {