From 97e4f8df57e4cf359c38459ff4141ac5a343f379 Mon Sep 17 00:00:00 2001 From: dengziming Date: Mon, 24 May 2021 11:02:06 +0800 Subject: [PATCH 1/3] MINOR: Add missing apiversion test for 3.0 --- core/src/test/scala/unit/kafka/api/ApiVersionTest.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/core/src/test/scala/unit/kafka/api/ApiVersionTest.scala b/core/src/test/scala/unit/kafka/api/ApiVersionTest.scala index a520cba344289..9b216b0d91ff7 100644 --- a/core/src/test/scala/unit/kafka/api/ApiVersionTest.scala +++ b/core/src/test/scala/unit/kafka/api/ApiVersionTest.scala @@ -119,6 +119,9 @@ class ApiVersionTest { assertEquals(KAFKA_2_8_IV1, ApiVersion("2.8")) assertEquals(KAFKA_2_8_IV0, ApiVersion("2.8-IV0")) assertEquals(KAFKA_2_8_IV1, ApiVersion("2.8-IV1")) + + assertEquals(KAFKA_3_0_IV0, ApiVersion("3.0")) + assertEquals(KAFKA_3_0_IV0, ApiVersion("3.0-IV0")) } @Test @@ -167,6 +170,7 @@ class ApiVersionTest { assertEquals("2.6", KAFKA_2_6_IV0.shortVersion) assertEquals("2.7", KAFKA_2_7_IV2.shortVersion) assertEquals("2.8", KAFKA_2_8_IV0.shortVersion) + assertEquals("3.0", KAFKA_3_0_IV0.shortVersion) } @Test From 8378ffe98fee022c13109d4833ad3fde3ffd6ea6 Mon Sep 17 00:00:00 2001 From: dengziming Date: Fri, 25 Jun 2021 21:31:52 +0800 Subject: [PATCH 2/3] check V3.0.1 --- core/src/test/scala/unit/kafka/api/ApiVersionTest.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/core/src/test/scala/unit/kafka/api/ApiVersionTest.scala b/core/src/test/scala/unit/kafka/api/ApiVersionTest.scala index 9b216b0d91ff7..bf792347b1163 100644 --- a/core/src/test/scala/unit/kafka/api/ApiVersionTest.scala +++ b/core/src/test/scala/unit/kafka/api/ApiVersionTest.scala @@ -120,8 +120,9 @@ class ApiVersionTest { assertEquals(KAFKA_2_8_IV0, ApiVersion("2.8-IV0")) assertEquals(KAFKA_2_8_IV1, ApiVersion("2.8-IV1")) - assertEquals(KAFKA_3_0_IV0, ApiVersion("3.0")) + assertEquals(KAFKA_3_0_IV1, ApiVersion("3.0")) assertEquals(KAFKA_3_0_IV0, ApiVersion("3.0-IV0")) + assertEquals(KAFKA_3_0_IV1, ApiVersion("3.0-IV1")) } @Test @@ -171,6 +172,7 @@ class ApiVersionTest { assertEquals("2.7", KAFKA_2_7_IV2.shortVersion) assertEquals("2.8", KAFKA_2_8_IV0.shortVersion) assertEquals("3.0", KAFKA_3_0_IV0.shortVersion) + assertEquals("3.0", KAFKA_3_0_IV1.shortVersion) } @Test From 00767b304b6cf1be0232943c3410b05805e99590 Mon Sep 17 00:00:00 2001 From: dengziming Date: Sat, 26 Jun 2021 17:21:49 +0800 Subject: [PATCH 3/3] add 2.8.1 --- core/src/test/scala/unit/kafka/api/ApiVersionTest.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/test/scala/unit/kafka/api/ApiVersionTest.scala b/core/src/test/scala/unit/kafka/api/ApiVersionTest.scala index bf792347b1163..fe57d9ee52063 100644 --- a/core/src/test/scala/unit/kafka/api/ApiVersionTest.scala +++ b/core/src/test/scala/unit/kafka/api/ApiVersionTest.scala @@ -171,6 +171,7 @@ class ApiVersionTest { assertEquals("2.6", KAFKA_2_6_IV0.shortVersion) assertEquals("2.7", KAFKA_2_7_IV2.shortVersion) assertEquals("2.8", KAFKA_2_8_IV0.shortVersion) + assertEquals("2.8", KAFKA_2_8_IV1.shortVersion) assertEquals("3.0", KAFKA_3_0_IV0.shortVersion) assertEquals("3.0", KAFKA_3_0_IV1.shortVersion) }