This is an automated email from the ASF dual-hosted git repository. jsancio 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 809694a9f62 MINOR; Fix cluster size for migration tests (#14726) 809694a9f62 is described below commit 809694a9f62ee584f5bdc4324bc1e1aa821bb588 Author: José Armando García Sancio <jsan...@users.noreply.github.com> AuthorDate: Thu Nov 9 15:47:15 2023 -0800 MINOR; Fix cluster size for migration tests (#14726) Use smaller cluster sizes instead of the default cluster size Reviewers: David Arthur <mum...@gmail.com>, Ismael Juma <ism...@juma.me.uk> --- tests/kafkatest/tests/core/zookeeper_migration_test.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/tests/kafkatest/tests/core/zookeeper_migration_test.py b/tests/kafkatest/tests/core/zookeeper_migration_test.py index 2023aea152b..7ca1c6a8ec5 100644 --- a/tests/kafkatest/tests/core/zookeeper_migration_test.py +++ b/tests/kafkatest/tests/core/zookeeper_migration_test.py @@ -18,6 +18,7 @@ import time from ducktape.utils.util import wait_until from ducktape.mark import parametrize +from ducktape.mark.resource import cluster from ducktape.errors import TimeoutError from kafkatest.services.console_consumer import ConsoleConsumer @@ -85,6 +86,7 @@ class TestMigration(ProduceConsumeValidateTest): controller.stop_node(node) controller.start_node(node) + @cluster(num_nodes=7) @parametrize(roll_controller = True) @parametrize(roll_controller = False) def test_online_migration(self, roll_controller): @@ -131,6 +133,7 @@ class TestMigration(ProduceConsumeValidateTest): self.run_produce_consume_validate(core_test_action=partial(self.do_migration, roll_controller = roll_controller)) self.kafka.stop() + @cluster(num_nodes=7) @parametrize(metadata_quorum=isolated_kraft) def test_pre_migration_mode_3_4(self, metadata_quorum): """ @@ -203,6 +206,7 @@ class TestMigration(ProduceConsumeValidateTest): assert saw_expected_error, "Did not see expected ERROR log in the controller logs" + @cluster(num_nodes=5) def test_upgrade_after_3_4_migration(self): """ Perform a migration on version 3.4.0. Then do a rolling upgrade to 3.5+ and ensure we see @@ -282,6 +286,7 @@ class TestMigration(ProduceConsumeValidateTest): assert saw_expected_log, "Did not see expected INFO log after upgrading from a 3.4 migration" self.kafka.stop() + @cluster(num_nodes=5) def test_reconcile_kraft_to_zk(self): """ Perform a migration and delete a topic directly from ZK. Ensure that the topic is added back