Add support for Kafka 3.1.0

IBM · Jan 24, 2022 · ad89ab6 · ad89ab6
1 parent 31d757b
commit ad89ab6
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/dev.yml b/dev.yml
@@ -2,7 +2,7 @@ name: sarama
 
 up:
   - go:
-      version: '1.17.1'
+      version: '1.17.6'
 
 commands:
   test:

diff --git a/utils.go b/utils.go
@@ -178,6 +178,7 @@ var (
 	V2_8_0_0  = newKafkaVersion(2, 8, 0, 0)
 	V2_8_1_0  = newKafkaVersion(2, 8, 1, 0)
 	V3_0_0_0  = newKafkaVersion(3, 0, 0, 0)
+	V3_1_0_0  = newKafkaVersion(3, 1, 0, 0)
 
 	SupportedVersions = []KafkaVersion{
 		V0_8_2_0,
@@ -221,9 +222,10 @@ var (
 		V2_8_0_0,
 		V2_8_1_0,
 		V3_0_0_0,
+		V3_1_0_0,
 	}
 	MinVersion     = V0_8_2_0
-	MaxVersion     = V3_0_0_0
+	MaxVersion     = V3_1_0_0
 	DefaultVersion = V1_0_0_0
 )