chore: populate the missing kafka versions

As discussed under IBM#2034, should simplify linkedin/Burrow usage too.
agriffaut · Sep 20, 2021 · 1cdea0a · 1cdea0a
1 parent 94c8136
commit 1cdea0a
Show file tree

Hide file tree

Showing 2 changed files with 75 additions and 1 deletion.
diff --git a/utils.go b/utils.go
@@ -148,22 +148,35 @@ var (
 	V0_10_1_1 = newKafkaVersion(0, 10, 1, 1)
 	V0_10_2_0 = newKafkaVersion(0, 10, 2, 0)
 	V0_10_2_1 = newKafkaVersion(0, 10, 2, 1)
+	V0_10_2_2 = newKafkaVersion(0, 10, 2, 2)
 	V0_11_0_0 = newKafkaVersion(0, 11, 0, 0)
 	V0_11_0_1 = newKafkaVersion(0, 11, 0, 1)
 	V0_11_0_2 = newKafkaVersion(0, 11, 0, 2)
 	V1_0_0_0  = newKafkaVersion(1, 0, 0, 0)
+	V1_0_1_0  = newKafkaVersion(1, 0, 1, 0)
+	V1_0_2_0  = newKafkaVersion(1, 0, 2, 0)
 	V1_1_0_0  = newKafkaVersion(1, 1, 0, 0)
 	V1_1_1_0  = newKafkaVersion(1, 1, 1, 0)
 	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_1_1_0  = newKafkaVersion(2, 1, 1, 0)
 	V2_2_0_0  = newKafkaVersion(2, 2, 0, 0)
+	V2_2_1_0  = newKafkaVersion(2, 2, 1, 0)
+	V2_2_2_0  = newKafkaVersion(2, 2, 2, 0)
 	V2_3_0_0  = newKafkaVersion(2, 3, 0, 0)
+	V2_3_1_0  = newKafkaVersion(2, 3, 1, 0)
 	V2_4_0_0  = newKafkaVersion(2, 4, 0, 0)
+	V2_4_1_0  = newKafkaVersion(2, 4, 1, 0)
 	V2_5_0_0  = newKafkaVersion(2, 5, 0, 0)
+	V2_5_1_0  = newKafkaVersion(2, 5, 1, 0)
 	V2_6_0_0  = newKafkaVersion(2, 6, 0, 0)
+	V2_6_1_0  = newKafkaVersion(2, 6, 1, 0)
+	V2_6_2_0  = newKafkaVersion(2, 6, 2, 0)
 	V2_7_0_0  = newKafkaVersion(2, 7, 0, 0)
+	V2_7_1_0  = newKafkaVersion(2, 7, 1, 0)
 	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)
 
 	SupportedVersions = []KafkaVersion{
@@ -178,22 +191,35 @@ var (
 		V0_10_1_1,
 		V0_10_2_0,
 		V0_10_2_1,
+		V0_10_2_2,
 		V0_11_0_0,
 		V0_11_0_1,
 		V0_11_0_2,
 		V1_0_0_0,
+		V1_0_1_0,
+		V1_0_2_0,
 		V1_1_0_0,
 		V1_1_1_0,
 		V2_0_0_0,
 		V2_0_1_0,
 		V2_1_0_0,
+		V2_1_1_0,
 		V2_2_0_0,
+		V2_2_1_0,
+		V2_2_2_0,
 		V2_3_0_0,
+		V2_3_1_0,
 		V2_4_0_0,
+		V2_4_1_0,
 		V2_5_0_0,
+		V2_5_1_0,
 		V2_6_0_0,
+		V2_6_1_0,
+		V2_6_2_0,
 		V2_7_0_0,
+		V2_7_1_0,
 		V2_8_0_0,
+		V2_8_1_0,
 		V3_0_0_0,
 	}
 	MinVersion     = V0_8_2_0

diff --git a/utils_test.go b/utils_test.go
@@ -18,10 +18,58 @@ func TestVersionCompare(t *testing.T) {
 	if V0_8_2_1.IsAtLeast(V0_10_0_0) {
 		t.Error("0.8.2.1 >= 0.10.0.0")
 	}
+	if !V1_0_0_0.IsAtLeast(V0_9_0_0) {
+		t.Error("! 1.0.0.0 >= 0.9.0.0")
+	}
+	if V0_9_0_0.IsAtLeast(V1_0_0_0) {
+		t.Error("0.9.0.0 >= 1.0.0.0")
+	}
 }
 
 func TestVersionParsing(t *testing.T) {
-	validVersions := []string{"0.8.2.0", "0.8.2.1", "0.9.0.0", "0.10.2.0", "1.0.0"}
+	validVersions := []string{
+		"0.8.2.0",
+		"0.8.2.1",
+		"0.8.2.2",
+		"0.9.0.0",
+		"0.9.0.1",
+		"0.10.0.0",
+		"0.10.0.1",
+		"0.10.1.0",
+		"0.10.1.1",
+		"0.10.2.0",
+		"0.10.2.1",
+		"0.10.2.2",
+		"0.11.0.0",
+		"0.11.0.1",
+		"0.11.0.2",
+		"1.0.0",
+		"1.0.1",
+		"1.0.2",
+		"1.1.0",
+		"1.1.1",
+		"2.0.0",
+		"2.0.1",
+		"2.1.0",
+		"2.1.1",
+		"2.2.0",
+		"2.2.1",
+		"2.2.2",
+		"2.3.0",
+		"2.3.1",
+		"2.4.0",
+		"2.4.1",
+		"2.5.0",
+		"2.5.1",
+		"2.6.0",
+		"2.6.1",
+		"2.6.2",
+		"2.7.0",
+		"2.7.1",
+		"2.8.0",
+		"2.8.1",
+		"3.0.0",
+	}
 	for _, s := range validVersions {
 		v, err := ParseKafkaVersion(s)
 		if err != nil {