Skip to content

Commit

Permalink
Upgrade sarama to support Kafka 2.2.0
Browse files Browse the repository at this point in the history
  • Loading branch information
asaf400 committed Apr 24, 2019
1 parent f7de04f commit 5ef6943
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 1 deletion.
2 changes: 1 addition & 1 deletion Gopkg.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[[constraint]]
name = "github.com/Shopify/sarama"
version = "1.21.0"
version = "1.22.0"

[[constraint]]
name = "go.uber.org/zap"
Expand Down
1 change: 1 addition & 0 deletions core/internal/helpers/sarama.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit 5ef6943

Please sign in to comment.