This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 0e37eff75fd MINOR: Add 4.3.0 to core system tests (#22381)
0e37eff75fd is described below
commit 0e37eff75fd2b853979439e2d663a4ea6be7f627
Author: Mickael Maison <[email protected]>
AuthorDate: Wed May 27 12:22:23 2026 +0200
MINOR: Add 4.3.0 to core system tests (#22381)
It seems we did not add 4.2.0 when it was released, so fixed that too.
Reviewers: Chia-Ping Tsai <[email protected]>
---
.../tests/client/client_compatibility_features_test.py | 4 +++-
.../tests/client/client_compatibility_produce_consume_test.py | 4 +++-
.../kafkatest/tests/client/consumer_protocol_migration_test.py | 4 ++--
.../kafkatest/tests/core/compatibility_test_new_broker_test.py | 4 +++-
tests/kafkatest/tests/core/transactions_mixed_versions_test.py | 4 ++--
tests/kafkatest/tests/core/transactions_upgrade_test.py | 4 ++--
tests/kafkatest/tests/core/upgrade_test.py | 10 +++++-----
7 files changed, 20 insertions(+), 14 deletions(-)
diff --git a/tests/kafkatest/tests/client/client_compatibility_features_test.py
b/tests/kafkatest/tests/client/client_compatibility_features_test.py
index d2026bb6788..ada939bade3 100644
--- a/tests/kafkatest/tests/client/client_compatibility_features_test.py
+++ b/tests/kafkatest/tests/client/client_compatibility_features_test.py
@@ -29,7 +29,7 @@ from ducktape.tests.test import Test
from kafkatest.version import DEV_BRANCH, \
LATEST_2_1, LATEST_2_2, LATEST_2_3, LATEST_2_4, LATEST_2_5, LATEST_2_6,
LATEST_2_7, LATEST_2_8, \
LATEST_3_0, LATEST_3_1, LATEST_3_2, LATEST_3_3, LATEST_3_4, LATEST_3_5,
LATEST_3_6, LATEST_3_7, \
- LATEST_3_8, LATEST_3_9, LATEST_4_0, LATEST_4_1, KafkaVersion
+ LATEST_3_8, LATEST_3_9, LATEST_4_0, LATEST_4_1, LATEST_4_2, LATEST_4_3,
KafkaVersion
def get_broker_features(broker_version):
features = {}
@@ -127,6 +127,8 @@ class ClientCompatibilityFeaturesTest(Test):
@parametrize(broker_version=str(LATEST_3_9),
metadata_quorum=quorum.isolated_kraft)
@parametrize(broker_version=str(LATEST_4_0),
metadata_quorum=quorum.isolated_kraft)
@parametrize(broker_version=str(LATEST_4_1),
metadata_quorum=quorum.isolated_kraft)
+ @parametrize(broker_version=str(LATEST_4_2),
metadata_quorum=quorum.isolated_kraft)
+ @parametrize(broker_version=str(LATEST_4_3),
metadata_quorum=quorum.isolated_kraft)
def run_compatibility_test(self, broker_version,
metadata_quorum=quorum.zk):
if self.zk:
self.zk.start()
diff --git
a/tests/kafkatest/tests/client/client_compatibility_produce_consume_test.py
b/tests/kafkatest/tests/client/client_compatibility_produce_consume_test.py
index 2615d35ce47..f68d439c2ce 100644
--- a/tests/kafkatest/tests/client/client_compatibility_produce_consume_test.py
+++ b/tests/kafkatest/tests/client/client_compatibility_produce_consume_test.py
@@ -26,7 +26,7 @@ from kafkatest.utils import is_int_with_prefix
from kafkatest.version import DEV_BRANCH, \
LATEST_2_1, LATEST_2_2, LATEST_2_3, LATEST_2_4, LATEST_2_5, LATEST_2_6,
LATEST_2_7, LATEST_2_8, \
LATEST_3_0, LATEST_3_1, LATEST_3_2, LATEST_3_3, LATEST_3_4, LATEST_3_5,
LATEST_3_6, LATEST_3_7, \
- LATEST_3_8, LATEST_3_9, LATEST_4_0, LATEST_4_1, KafkaVersion
+ LATEST_3_8, LATEST_3_9, LATEST_4_0, LATEST_4_1, LATEST_4_2, LATEST_4_3,
KafkaVersion
class ClientCompatibilityProduceConsumeTest(ProduceConsumeValidateTest):
"""
@@ -87,6 +87,8 @@ class
ClientCompatibilityProduceConsumeTest(ProduceConsumeValidateTest):
@parametrize(broker_version=str(LATEST_3_9),
metadata_quorum=quorum.isolated_kraft)
@parametrize(broker_version=str(LATEST_4_0),
metadata_quorum=quorum.isolated_kraft)
@parametrize(broker_version=str(LATEST_4_1),
metadata_quorum=quorum.isolated_kraft)
+ @parametrize(broker_version=str(LATEST_4_2),
metadata_quorum=quorum.isolated_kraft)
+ @parametrize(broker_version=str(LATEST_4_3),
metadata_quorum=quorum.isolated_kraft)
def test_produce_consume(self, broker_version, metadata_quorum=quorum.zk):
print("running producer_consumer_compat with broker_version = %s" %
broker_version, flush=True)
self.kafka.set_version(KafkaVersion(broker_version))
diff --git a/tests/kafkatest/tests/client/consumer_protocol_migration_test.py
b/tests/kafkatest/tests/client/consumer_protocol_migration_test.py
index bfe5a1eebaa..4e292f6b4c5 100644
--- a/tests/kafkatest/tests/client/consumer_protocol_migration_test.py
+++ b/tests/kafkatest/tests/client/consumer_protocol_migration_test.py
@@ -21,7 +21,7 @@ from kafkatest.tests.verifiable_consumer_test import
VerifiableConsumerTest
from kafkatest.services.kafka import TopicPartition, quorum, consumer_group
from kafkatest.version import LATEST_2_1, LATEST_2_3, LATEST_2_4, LATEST_2_5, \
LATEST_3_2, LATEST_3_4, LATEST_3_5, LATEST_3_6, LATEST_3_7, LATEST_3_8,
LATEST_3_9, \
- LATEST_4_0, LATEST_4_1, DEV_BRANCH, KafkaVersion
+ LATEST_4_0, LATEST_4_1, LATEST_4_2, LATEST_4_3, DEV_BRANCH, KafkaVersion
class ConsumerProtocolMigrationTest(VerifiableConsumerTest):
"""
@@ -45,7 +45,7 @@ class ConsumerProtocolMigrationTest(VerifiableConsumerTest):
all_consumer_versions = [LATEST_2_1, LATEST_2_3, LATEST_2_4, LATEST_2_5, \
LATEST_3_2, LATEST_3_4, LATEST_3_5, LATEST_3_6, \
LATEST_3_7, LATEST_3_8, LATEST_3_9, LATEST_4_0, \
- LATEST_4_1, \
+ LATEST_4_1, LATEST_4_2, LATEST_4_3, \
DEV_BRANCH]
consumer_versions_supporting_range_assignnor = [str(v) for v in
all_consumer_versions]
consumer_versions_supporting_static_membership = [str(v) for v in
all_consumer_versions if v >= LATEST_2_3]
diff --git a/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
b/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
index cabf2922f40..8d5ae48956f 100644
--- a/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
+++ b/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
@@ -22,7 +22,7 @@ from kafkatest.tests.produce_consume_validate import
ProduceConsumeValidateTest
from kafkatest.utils import is_int
from kafkatest.version import LATEST_2_1, LATEST_2_2, LATEST_2_3, LATEST_2_4,
LATEST_2_5, LATEST_2_6, \
LATEST_2_7, LATEST_2_8, LATEST_3_0, LATEST_3_1, LATEST_3_2, LATEST_3_3,
LATEST_3_4, LATEST_3_5, LATEST_3_6, \
- LATEST_3_7, LATEST_3_8, LATEST_3_9, LATEST_4_0, LATEST_4_1, DEV_BRANCH,
KafkaVersion
+ LATEST_3_7, LATEST_3_8, LATEST_3_9, LATEST_4_0, LATEST_4_1, LATEST_4_2,
LATEST_4_3, DEV_BRANCH, KafkaVersion
# Compatibility tests for moving to a new broker (e.g., 0.10.x) and using a
mix of old and new clients (e.g., 0.9.x)
class ClientCompatibilityTestNewBroker(ProduceConsumeValidateTest):
@@ -62,6 +62,8 @@ class
ClientCompatibilityTestNewBroker(ProduceConsumeValidateTest):
@matrix(producer_version=[str(LATEST_3_9)],
consumer_version=[str(LATEST_3_9)], compression_types=[["none"]],
timestamp_type=[str("CreateTime")], metadata_quorum=quorum.all_non_upgrade)
@matrix(producer_version=[str(LATEST_4_0)],
consumer_version=[str(LATEST_4_0)], compression_types=[["none"]],
timestamp_type=[str("CreateTime")], metadata_quorum=quorum.all_non_upgrade)
@matrix(producer_version=[str(LATEST_4_1)],
consumer_version=[str(LATEST_4_1)], compression_types=[["none"]],
timestamp_type=[str("CreateTime")], metadata_quorum=quorum.all_non_upgrade)
+ @matrix(producer_version=[str(LATEST_4_2)],
consumer_version=[str(LATEST_4_2)], compression_types=[["none"]],
timestamp_type=[str("CreateTime")], metadata_quorum=quorum.all_non_upgrade)
+ @matrix(producer_version=[str(LATEST_4_3)],
consumer_version=[str(LATEST_4_3)], compression_types=[["none"]],
timestamp_type=[str("CreateTime")], metadata_quorum=quorum.all_non_upgrade)
@matrix(producer_version=[str(LATEST_2_1)],
consumer_version=[str(LATEST_2_1)], compression_types=[["zstd"]],
timestamp_type=[str("CreateTime")], metadata_quorum=quorum.all_non_upgrade)
def test_compatibility(self, producer_version, consumer_version,
compression_types, timestamp_type=None, metadata_quorum=quorum.zk):
self.kafka = KafkaService(self.test_context, num_nodes=3, zk=None,
version=DEV_BRANCH, topics={self.topic: {
diff --git a/tests/kafkatest/tests/core/transactions_mixed_versions_test.py
b/tests/kafkatest/tests/core/transactions_mixed_versions_test.py
index ed98dffd169..0ffae1edc08 100644
--- a/tests/kafkatest/tests/core/transactions_mixed_versions_test.py
+++ b/tests/kafkatest/tests/core/transactions_mixed_versions_test.py
@@ -22,7 +22,7 @@ from kafkatest.utils import is_int
from kafkatest.utils.transactions_utils import create_and_start_copiers
from kafkatest.version import LATEST_3_3, LATEST_3_4, LATEST_3_5, \
LATEST_3_6, LATEST_3_7, LATEST_3_8, LATEST_3_9, LATEST_4_0, \
- LATEST_4_1, LATEST_4_2, DEV_BRANCH, KafkaVersion,
LATEST_STABLE_METADATA_VERSION
+ LATEST_4_1, LATEST_4_2, LATEST_4_3, DEV_BRANCH, KafkaVersion,
LATEST_STABLE_METADATA_VERSION
from ducktape.tests.test import Test
from ducktape.mark import matrix
@@ -190,7 +190,7 @@ class TransactionsMixedVersionsTest(Test):
@cluster(num_nodes=8)
@matrix(
- old_kafka_version=[str(LATEST_4_2), str(LATEST_4_1), str(LATEST_4_0),
str(LATEST_3_9), str(LATEST_3_8), str(LATEST_3_7), str(LATEST_3_6),
str(LATEST_3_5), str(LATEST_3_4), str(LATEST_3_3)],
+ old_kafka_version=[str(LATEST_4_3), str(LATEST_4_2), str(LATEST_4_1),
str(LATEST_4_0), str(LATEST_3_9), str(LATEST_3_8), str(LATEST_3_7),
str(LATEST_3_6), str(LATEST_3_5), str(LATEST_3_4), str(LATEST_3_3)],
metadata_quorum=[isolated_kraft],
group_protocol=[None],
coordinator_on_new_broker=[True, False]
diff --git a/tests/kafkatest/tests/core/transactions_upgrade_test.py
b/tests/kafkatest/tests/core/transactions_upgrade_test.py
index 724605c6b24..af536507ab4 100644
--- a/tests/kafkatest/tests/core/transactions_upgrade_test.py
+++ b/tests/kafkatest/tests/core/transactions_upgrade_test.py
@@ -22,7 +22,7 @@ from kafkatest.utils import is_int
from kafkatest.utils.transactions_utils import create_and_start_copiers
from kafkatest.version import LATEST_3_3, LATEST_3_4, LATEST_3_5, \
LATEST_3_6, LATEST_3_7, LATEST_3_8, LATEST_3_9, LATEST_4_0, \
- LATEST_4_1, DEV_BRANCH, KafkaVersion, LATEST_STABLE_METADATA_VERSION,
LATEST_STABLE_TRANSACTION_VERSION
+ LATEST_4_1, LATEST_4_2, LATEST_4_3, DEV_BRANCH, KafkaVersion,
LATEST_STABLE_METADATA_VERSION, LATEST_STABLE_TRANSACTION_VERSION
from ducktape.tests.test import Test
from ducktape.mark import matrix
@@ -209,7 +209,7 @@ class TransactionsUpgradeTest(Test):
@cluster(num_nodes=8)
@matrix(
- from_kafka_version=[str(LATEST_4_1), str(LATEST_4_0), str(LATEST_3_9),
str(LATEST_3_8), str(LATEST_3_7), str(LATEST_3_6), str(LATEST_3_5),
str(LATEST_3_4), str(LATEST_3_3)],
+ from_kafka_version=[str(LATEST_4_3), str(LATEST_4_2), str(LATEST_4_1),
str(LATEST_4_0), str(LATEST_3_9), str(LATEST_3_8), str(LATEST_3_7),
str(LATEST_3_6), str(LATEST_3_5), str(LATEST_3_4), str(LATEST_3_3)],
metadata_quorum=[isolated_kraft],
group_protocol=[None]
)
diff --git a/tests/kafkatest/tests/core/upgrade_test.py
b/tests/kafkatest/tests/core/upgrade_test.py
index 50cb345a4be..123efb8da75 100644
--- a/tests/kafkatest/tests/core/upgrade_test.py
+++ b/tests/kafkatest/tests/core/upgrade_test.py
@@ -24,7 +24,7 @@ from kafkatest.tests.produce_consume_validate import
ProduceConsumeValidateTest
from kafkatest.utils import is_int
from kafkatest.version import LATEST_3_4, LATEST_3_5, \
LATEST_3_6, LATEST_3_7, LATEST_3_8, LATEST_3_9, LATEST_4_0, \
- LATEST_4_1, DEV_BRANCH, KafkaVersion, LATEST_STABLE_METADATA_VERSION
+ LATEST_4_1, LATEST_4_2, LATEST_4_3, DEV_BRANCH, KafkaVersion,
LATEST_STABLE_METADATA_VERSION
#
# Test upgrading between different KRaft versions.
@@ -164,25 +164,25 @@ class TestUpgrade(ProduceConsumeValidateTest):
assert self.kafka.check_protocol_errors(self)
@cluster(num_nodes=5)
- @matrix(from_kafka_version=[str(LATEST_3_4), str(LATEST_3_5),
str(LATEST_3_6), str(LATEST_3_7), str(LATEST_3_8), str(LATEST_3_9),
str(LATEST_4_0), str(LATEST_4_1), str(DEV_BRANCH)],
+ @matrix(from_kafka_version=[str(LATEST_3_4), str(LATEST_3_5),
str(LATEST_3_6), str(LATEST_3_7), str(LATEST_3_8), str(LATEST_3_9),
str(LATEST_4_0), str(LATEST_4_1), str(LATEST_4_2), str(LATEST_4_3),
str(DEV_BRANCH)],
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)
- @matrix(from_kafka_version=[str(LATEST_3_4), str(LATEST_3_5),
str(LATEST_3_6), str(LATEST_3_7), str(LATEST_3_8), str(LATEST_3_9),
str(LATEST_4_0), str(LATEST_4_1), str(DEV_BRANCH)],
+ @matrix(from_kafka_version=[str(LATEST_3_4), str(LATEST_3_5),
str(LATEST_3_6), str(LATEST_3_7), str(LATEST_3_8), str(LATEST_3_9),
str(LATEST_4_0), str(LATEST_4_1), str(LATEST_4_2), str(LATEST_4_3),
str(DEV_BRANCH)],
metadata_quorum=[isolated_kraft])
def test_isolated_mode_upgrade(self, from_kafka_version, metadata_quorum):
self.run_upgrade(from_kafka_version)
@cluster(num_nodes=5)
- @matrix(from_kafka_version=[str(LATEST_3_4), str(LATEST_3_5),
str(LATEST_3_6), str(LATEST_3_7), str(LATEST_3_8), str(LATEST_3_9),
str(LATEST_4_0), str(LATEST_4_1), str(DEV_BRANCH)],
+ @matrix(from_kafka_version=[str(LATEST_3_4), str(LATEST_3_5),
str(LATEST_3_6), str(LATEST_3_7), str(LATEST_3_8), str(LATEST_3_9),
str(LATEST_4_0), str(LATEST_4_1), str(LATEST_4_2), str(LATEST_4_3),
str(DEV_BRANCH)],
metadata_quorum=[combined_kraft])
def test_combined_mode_upgrade_downgrade(self, from_kafka_version,
metadata_quorum):
self.run_upgrade_downgrade(from_kafka_version)
@cluster(num_nodes=8)
- @matrix(from_kafka_version=[str(LATEST_3_4), str(LATEST_3_5),
str(LATEST_3_6), str(LATEST_3_7), str(LATEST_3_8), str(LATEST_3_9),
str(LATEST_4_0), str(LATEST_4_1), str(DEV_BRANCH)],
+ @matrix(from_kafka_version=[str(LATEST_3_4), str(LATEST_3_5),
str(LATEST_3_6), str(LATEST_3_7), str(LATEST_3_8), str(LATEST_3_9),
str(LATEST_4_0), str(LATEST_4_1), str(LATEST_4_2), str(LATEST_4_3),
str(DEV_BRANCH)],
metadata_quorum=[isolated_kraft])
def test_isolated_mode_upgrade_downgrade(self, from_kafka_version,
metadata_quorum):
self.run_upgrade_downgrade(from_kafka_version)
