[MINOR] Add latest versions to kraft upgrade kafkatest (apache#14084)

Reviewers: Ron Dagostino <rndgstn@gmail.com>
rreddy-22 · Jul 27, 2023 · e5861ee · e5861ee
1 parent 6f39ef0
commit e5861ee
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 3 deletions.
diff --git a/tests/kafkatest/tests/core/kraft_upgrade_test.py b/tests/kafkatest/tests/core/kraft_upgrade_test.py
@@ -22,8 +22,8 @@
 from kafkatest.services.verifiable_producer import VerifiableProducer
 from kafkatest.tests.produce_consume_validate import ProduceConsumeValidateTest
 from kafkatest.utils import is_int
-from kafkatest.version import LATEST_3_0, LATEST_3_1, LATEST_3_2, DEV_BRANCH, \
-    KafkaVersion, LATEST_METADATA_VERSION
+from kafkatest.version import LATEST_3_1, LATEST_3_2, LATEST_3_3, LATEST_3_4, LATEST_3_5, \
+    DEV_BRANCH, DEV_VERSION, KafkaVersion, LATEST_METADATA_VERSION
 
 #
 # Test upgrading between different KRaft versions.
@@ -111,12 +111,20 @@ def run_upgrade(self, from_kafka_version):
     @cluster(num_nodes=5)
     @parametrize(from_kafka_version=str(LATEST_3_1), metadata_quorum=combined_kraft)
     @parametrize(from_kafka_version=str(LATEST_3_2), metadata_quorum=combined_kraft)
+    @parametrize(from_kafka_version=str(LATEST_3_3), metadata_quorum=combined_kraft)
+    @parametrize(from_kafka_version=str(LATEST_3_4), metadata_quorum=combined_kraft)
+    @parametrize(from_kafka_version=str(LATEST_3_5), metadata_quorum=combined_kraft)
+    @parametrize(from_kafka_version=str(DEV_VERSION), metadata_quorum=combined_kraft)
     def test_combined_mode_upgrade(self, from_kafka_version, metadata_quorum):
         self.run_upgrade(from_kafka_version)
 
     @cluster(num_nodes=8)
     @parametrize(from_kafka_version=str(LATEST_3_1), metadata_quorum=isolated_kraft)
     @parametrize(from_kafka_version=str(LATEST_3_2), metadata_quorum=isolated_kraft)
+    @parametrize(from_kafka_version=str(LATEST_3_3), metadata_quorum=isolated_kraft)
+    @parametrize(from_kafka_version=str(LATEST_3_4), metadata_quorum=isolated_kraft)
+    @parametrize(from_kafka_version=str(LATEST_3_5), metadata_quorum=isolated_kraft)
+    @parametrize(from_kafka_version=str(DEV_VERSION), metadata_quorum=isolated_kraft)
     def test_isolated_mode_upgrade(self, from_kafka_version, metadata_quorum):
         self.run_upgrade(from_kafka_version)
 
diff --git a/tests/kafkatest/version.py b/tests/kafkatest/version.py
@@ -122,7 +122,7 @@ def get_version(node=None):
 DEV_BRANCH = KafkaVersion("dev")
 DEV_VERSION = KafkaVersion("3.6.0-SNAPSHOT")
 
-LATEST_METADATA_VERSION = "3.3"
+LATEST_METADATA_VERSION = "3.6"
 
 # 0.8.2.x versions
 V_0_8_2_1 = KafkaVersion("0.8.2.1")
@@ -252,3 +252,7 @@ def get_version(node=None):
 V_3_5_0 = KafkaVersion("3.5.0")
 V_3_5_1 = KafkaVersion("3.5.1")
 LATEST_3_5 = V_3_5_1
+
+# 3.6.x versions
+V_3_6_0 = KafkaVersion("3.6.0")
+LATEST_3_6 = V_3_6_0