Add support for kafka 2.5.0

IBM · Apr 15, 2020 · 1c61292 · 1c61292
1 parent 6159078
commit 1c61292
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -10,7 +10,7 @@ jobs:
       fail-fast: false
       matrix:
         go-version: [1.12.x, 1.13.x, 1.14.x]
-        kafka-version: [2.3.1, 2.4.0]
+        kafka-version: [2.3.1, 2.4.0, 2.5.0]
         platform: [ubuntu-latest]
 
     env:

diff --git a/utils.go b/utils.go
@@ -160,6 +160,7 @@ var (
 	V2_2_0_0  = newKafkaVersion(2, 2, 0, 0)
 	V2_3_0_0  = newKafkaVersion(2, 3, 0, 0)
 	V2_4_0_0  = newKafkaVersion(2, 4, 0, 0)
+	V2_5_0_0  = newKafkaVersion(2, 5, 0, 0)
 
 	SupportedVersions = []KafkaVersion{
 		V0_8_2_0,
@@ -185,9 +186,10 @@ var (
 		V2_2_0_0,
 		V2_3_0_0,
 		V2_4_0_0,
+		V2_5_0_0,
 	}
 	MinVersion = V0_8_2_0
-	MaxVersion = V2_4_0_0
+	MaxVersion = V2_5_0_0
 )
 
 //ParseKafkaVersion parses and returns kafka version or error from a string