root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

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

Reviewers: Ron Dagostino <rndgstn@gmail.com>
This commit is contained in:
Alyssa Huang 2023-07-27 13:12:25 -07:00 committed by GitHub
parent 6f39ef02ca
commit e5861eeaae
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/kafkatest/tests/core/kraft_upgrade_test.py
View File

@ -22,8 +22,8 @@ from kafkatest.services.kafka.quorum import isolated_kraft, combined_kraft
from kafkatest.services.verifiable_producer import VerifiableProducer from kafkatest.services.verifiable_producer import VerifiableProducer
from kafkatest.tests.produce_consume_validate import ProduceConsumeValidateTest from kafkatest.tests.produce_consume_validate import ProduceConsumeValidateTest
from kafkatest.utils import is_int from kafkatest.utils import is_int
from kafkatest.version import LATEST_3_0, LATEST_3_1, LATEST_3_2, DEV_BRANCH, \ from kafkatest.version import LATEST_3_1, LATEST_3_2, LATEST_3_3, LATEST_3_4, LATEST_3_5, \
KafkaVersion, LATEST_METADATA_VERSION DEV_BRANCH, DEV_VERSION, KafkaVersion, LATEST_METADATA_VERSION
# #
# Test upgrading between different KRaft versions. # Test upgrading between different KRaft versions.
@ -111,12 +111,20 @@ class TestKRaftUpgrade(ProduceConsumeValidateTest):
@cluster(num_nodes=5) @cluster(num_nodes=5)
@parametrize(from_kafka_version=str(LATEST_3_1), metadata_quorum=combined_kraft) @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_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): def test_combined_mode_upgrade(self, from_kafka_version, metadata_quorum):
self.run_upgrade(from_kafka_version) self.run_upgrade(from_kafka_version)
@cluster(num_nodes=8) @cluster(num_nodes=8)
@parametrize(from_kafka_version=str(LATEST_3_1), metadata_quorum=isolated_kraft) @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_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): def test_isolated_mode_upgrade(self, from_kafka_version, metadata_quorum):
self.run_upgrade(from_kafka_version) self.run_upgrade(from_kafka_version)

6
tests/kafkatest/version.py
View File

@ -122,7 +122,7 @@ def get_version(node=None):
DEV_BRANCH = KafkaVersion("dev") DEV_BRANCH = KafkaVersion("dev")
DEV_VERSION = KafkaVersion("3.6.0-SNAPSHOT") DEV_VERSION = KafkaVersion("3.6.0-SNAPSHOT")
LATEST_METADATA_VERSION = "3.3" LATEST_METADATA_VERSION = "3.6"
# 0.8.2.x versions # 0.8.2.x versions
V_0_8_2_1 = KafkaVersion("0.8.2.1") V_0_8_2_1 = KafkaVersion("0.8.2.1")
@ -252,3 +252,7 @@ LATEST_3_4 = V_3_4_1
V_3_5_0 = KafkaVersion("3.5.0") V_3_5_0 = KafkaVersion("3.5.0")
V_3_5_1 = KafkaVersion("3.5.1") V_3_5_1 = KafkaVersion("3.5.1")
LATEST_3_5 = V_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