Browse Source

Add support for kafka 2.4.0

Vlad Gorodetsky 6 years ago
parent
commit
0adc8d5a15
4 changed files with 5 additions and 4 deletions
  1. 0 1
      .travis.yml
  2. 1 1
      README.md
  3. 1 1
      dev.yml
  4. 3 1
      utils.go

+ 0 - 1
.travis.yml

@@ -1,7 +1,6 @@
 dist: xenial
 dist: xenial
 language: go
 language: go
 go:
 go:
-- 1.11.x
 - 1.12.x
 - 1.12.x
 - 1.13.x
 - 1.13.x
 
 

+ 1 - 1
README.md

@@ -20,7 +20,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.11 through 1.13, and Kafka 2.1 through 2.3, although older releases are
+Go 1.12 through 1.13, and Kafka 2.1 through 2.4, 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.

+ 1 - 1
dev.yml

@@ -2,7 +2,7 @@ name: sarama
 
 
 up:
 up:
   - go:
   - go:
-      version: '1.13.1'
+      version: '1.13.4'
 
 
 commands:
 commands:
   test:
   test:

+ 3 - 1
utils.go

@@ -161,6 +161,7 @@ var (
 	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)
 	V2_3_0_0  = newKafkaVersion(2, 3, 0, 0)
+	V2_4_0_0  = newKafkaVersion(2, 4, 0, 0)
 
 
 	SupportedVersions = []KafkaVersion{
 	SupportedVersions = []KafkaVersion{
 		V0_8_2_0,
 		V0_8_2_0,
@@ -185,9 +186,10 @@ var (
 		V2_1_0_0,
 		V2_1_0_0,
 		V2_2_0_0,
 		V2_2_0_0,
 		V2_3_0_0,
 		V2_3_0_0,
+		V2_4_0_0,
 	}
 	}
 	MinVersion = V0_8_2_0
 	MinVersion = V0_8_2_0
-	MaxVersion = V2_3_0_0
+	MaxVersion = V2_4_0_0
 )
 )
 
 
 //ParseKafkaVersion parses and returns kafka version or error from a string
 //ParseKafkaVersion parses and returns kafka version or error from a string