Skip to content

Commit

Permalink
Merge pull request #1293 from Shopify/kafka220
Browse files Browse the repository at this point in the history
Add support for Kafka 2.2.0
  • Loading branch information
bai committed Feb 25, 2019
2 parents 4602b5a + 0ad24a7 commit a283804
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
4 changes: 3 additions & 1 deletion utils.go
Original file line number Diff line number Diff line change
Expand Up @@ -159,6 +159,7 @@ var (
V2_0_0_0 = newKafkaVersion(2, 0, 0, 0)
V2_0_1_0 = newKafkaVersion(2, 0, 1, 0)
V2_1_0_0 = newKafkaVersion(2, 1, 0, 0)
V2_2_0_0 = newKafkaVersion(2, 2, 0, 0)

SupportedVersions = []KafkaVersion{
V0_8_2_0,
Expand All @@ -181,9 +182,10 @@ var (
V2_0_0_0,
V2_0_1_0,
V2_1_0_0,
V2_2_0_0,
}
MinVersion = V0_8_2_0
MaxVersion = V2_1_0_0
MaxVersion = V2_2_0_0
)

func ParseKafkaVersion(s string) (KafkaVersion, error) {
Expand Down
2 changes: 1 addition & 1 deletion vagrant/install_cluster.sh
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

set -ex

TOXIPROXY_VERSION=2.1.3
TOXIPROXY_VERSION=2.1.4

mkdir -p ${KAFKA_INSTALL_ROOT}
if [ ! -f ${KAFKA_INSTALL_ROOT}/kafka-${KAFKA_VERSION}.tgz ]; then
Expand Down

0 comments on commit a283804

Please sign in to comment.