Skip to content

Commit

Permalink
MINOR; Fix cluster size for migration tests (#14726)
Browse files Browse the repository at this point in the history
Use smaller cluster sizes instead of the default cluster size

Reviewers: David Arthur <mumrah@gmail.com>, Ismael Juma <ismael@juma.me.uk>
  • Loading branch information
jsancio committed Nov 9, 2023
1 parent 35317d8 commit 809694a
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions tests/kafkatest/tests/core/zookeeper_migration_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@

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
Expand Down Expand Up @@ -85,6 +86,7 @@ def do_migration(self, roll_controller = False, downgrade_to_zk = False):
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):
Expand Down Expand Up @@ -131,6 +133,7 @@ def test_online_migration(self, roll_controller):
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):
"""
Expand Down Expand Up @@ -203,6 +206,7 @@ def test_pre_migration_mode_3_4(self, metadata_quorum):

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
Expand Down Expand Up @@ -282,6 +286,7 @@ def test_upgrade_after_3_4_migration(self):
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
Expand Down

0 comments on commit 809694a

Please sign in to comment.