Browse Source

Merge pull request #1418 from Shopify/kafka230

Add support for Kafka 2.3.0
Vlad Gorodetsky 5 years ago
parent
commit
2e586779ca
3 changed files with 6 additions and 3 deletions
  1. 2 1
      .travis.yml
  2. 1 1
      README.md
  3. 3 1
      utils.go

+ 2 - 1
.travis.yml

@@ -13,7 +13,8 @@ env:
   - DEBUG=true
   - DEBUG=true
   matrix:
   matrix:
   - KAFKA_VERSION=2.1.1 KAFKA_SCALA_VERSION=2.12
   - KAFKA_VERSION=2.1.1 KAFKA_SCALA_VERSION=2.12
-  - KAFKA_VERSION=2.2.0 KAFKA_SCALA_VERSION=2.12
+  - KAFKA_VERSION=2.2.1 KAFKA_SCALA_VERSION=2.12
+  - KAFKA_VERSION=2.3.0 KAFKA_SCALA_VERSION=2.12
 
 
 before_install:
 before_install:
 - export REPOSITORY_ROOT=${TRAVIS_BUILD_DIR}
 - export REPOSITORY_ROOT=${TRAVIS_BUILD_DIR}

+ 1 - 1
README.md

@@ -21,7 +21,7 @@ You might also want to look at the [Frequently Asked Questions](https://github.c
 Sarama provides a "2 releases + 2 months" compatibility guarantee: we support
 Sarama provides a "2 releases + 2 months" compatibility guarantee: we support
 the two latest stable releases of Kafka and Go, and we provide a two month
 the two latest stable releases of Kafka and Go, and we provide a two month
 grace period for older releases. This means we currently officially support
 grace period for older releases. This means we currently officially support
-Go 1.10 through 1.12, and Kafka 2.0 through 2.2, although older releases are
+Go 1.11 through 1.12, and Kafka 2.0 through 2.3, although older releases are
 still likely to work.
 still likely to work.
 
 
 Sarama follows semantic versioning and provides API stability via the gopkg.in service.
 Sarama follows semantic versioning and provides API stability via the gopkg.in service.

+ 3 - 1
utils.go

@@ -160,6 +160,7 @@ var (
 	V2_0_1_0  = newKafkaVersion(2, 0, 1, 0)
 	V2_0_1_0  = newKafkaVersion(2, 0, 1, 0)
 	V2_1_0_0  = newKafkaVersion(2, 1, 0, 0)
 	V2_1_0_0  = newKafkaVersion(2, 1, 0, 0)
 	V2_2_0_0  = newKafkaVersion(2, 2, 0, 0)
 	V2_2_0_0  = newKafkaVersion(2, 2, 0, 0)
+	V2_3_0_0  = newKafkaVersion(2, 3, 0, 0)
 
 
 	SupportedVersions = []KafkaVersion{
 	SupportedVersions = []KafkaVersion{
 		V0_8_2_0,
 		V0_8_2_0,
@@ -183,9 +184,10 @@ var (
 		V2_0_1_0,
 		V2_0_1_0,
 		V2_1_0_0,
 		V2_1_0_0,
 		V2_2_0_0,
 		V2_2_0_0,
+		V2_3_0_0,
 	}
 	}
 	MinVersion = V0_8_2_0
 	MinVersion = V0_8_2_0
-	MaxVersion = V2_2_0_0
+	MaxVersion = V2_3_0_0
 )
 )
 
 
 //ParseKafkaVersion parses and returns kafka version or error from a string
 //ParseKafkaVersion parses and returns kafka version or error from a string