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

MINOR: KRaft upgrade tests should only use latest stable mv (#15566) 

This should help us avoid testing MVs before they are usable (stable).
We revert back from testing 3.8 in this case since 3.7 is the current stable version.

Reviewers: Proven Provenzano <pprovenzano@confluent.io>, Justine Olshan <jolshan@confluent.io>
This commit is contained in:
Alyssa Huang 2024-03-21 11:06:40 -07:00 committed by GitHub
parent c5804e7649
commit 7e85d7d32e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -23,7 +23,7 @@ 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_1, LATEST_3_2, LATEST_3_3, LATEST_3_4, LATEST_3_5, \
DEV_BRANCH, KafkaVersion, LATEST_METADATA_VERSION
DEV_BRANCH, KafkaVersion, LATEST_STABLE_METADATA_VERSION
#
# Test upgrading between different KRaft versions.
@ -71,8 +71,8 @@ class TestKRaftUpgrade(ProduceConsumeValidateTest):
self.kafka.start_node(node)
self.wait_until_rejoin()
self.logger.info("Successfully restarted broker node %s" % node.account.hostname)
self.logger.info("Changing metadata.version to %s" % LATEST_METADATA_VERSION)
self.kafka.upgrade_metadata_version(LATEST_METADATA_VERSION)
self.logger.info("Changing metadata.version to %s" % LATEST_STABLE_METADATA_VERSION)
self.kafka.upgrade_metadata_version(LATEST_STABLE_METADATA_VERSION)
def run_upgrade(self, from_kafka_version):
"""Test upgrade of Kafka broker cluster from various versions to the current version

3
tests/kafkatest/version.py
View File

@ -124,7 +124,8 @@ def get_version(node=None):
DEV_BRANCH = KafkaVersion("dev")
DEV_VERSION = KafkaVersion("3.8.0-SNAPSHOT")
LATEST_METADATA_VERSION = "3.8"
# This should match the LATEST_PRODUCTION version defined in MetadataVersion.java
LATEST_STABLE_METADATA_VERSION = "3.7"
# 0.8.2.x versions
V_0_8_2_1 = KafkaVersion("0.8.2.1")