(kafka) branch trunk updated: MINOR; Fix cluster size for migration tests (#14726)

[js...@apache.org]

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 <js...@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 <mu...@gmail.com>, Ismael Juma <is...@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