diff --git a/utils.go b/utils.go index 14070a83f..4abe8f197 100644 --- a/utils.go +++ b/utils.go @@ -173,8 +173,10 @@ var ( 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_6_3_0 = newKafkaVersion(2, 6, 3, 0) V2_7_0_0 = newKafkaVersion(2, 7, 0, 0) V2_7_1_0 = newKafkaVersion(2, 7, 1, 0) + V2_7_2_0 = newKafkaVersion(2, 7, 2, 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) diff --git a/utils_test.go b/utils_test.go index 70fcbec93..3d2c3ac89 100644 --- a/utils_test.go +++ b/utils_test.go @@ -64,8 +64,10 @@ func TestVersionParsing(t *testing.T) { "2.6.0", "2.6.1", "2.6.2", + "2.6.3", "2.7.0", "2.7.1", + "2.7.2", "2.8.0", "2.8.1", "3.0.0",