[kafka] branch trunk updated: MINOR: fix zookeeper_migration_test.py (#13620)

[chia7712]

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 2271e748a11 MINOR: fix zookeeper_migration_test.py (#13620)
2271e748a11 is described below

commit 2271e748a11919d07698ebce759dca2e3075596a
Author: Chia-Ping Tsai <chia7...@gmail.com>
AuthorDate: Mon Apr 24 17:21:19 2023 +0800

    MINOR: fix zookeeper_migration_test.py (#13620)
    
    Reviewers: Mickael Maison <mimai...@users.noreply.github.com>
---
 tests/kafkatest/tests/core/zookeeper_migration_test.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/tests/kafkatest/tests/core/zookeeper_migration_test.py 
b/tests/kafkatest/tests/core/zookeeper_migration_test.py
index 257b9f79158..a9a75eb8086 100644
--- a/tests/kafkatest/tests/core/zookeeper_migration_test.py
+++ b/tests/kafkatest/tests/core/zookeeper_migration_test.py
@@ -21,7 +21,7 @@ from ducktape.utils.util import wait_until
 from kafkatest.services.console_consumer import ConsoleConsumer
 from kafkatest.services.kafka import KafkaService
 from kafkatest.services.kafka.config_property import CLUSTER_ID
-from kafkatest.services.kafka.quorum import remote_kraft, ServiceQuorumInfo, zk
+from kafkatest.services.kafka.quorum import isolated_kraft, ServiceQuorumInfo, 
zk
 from kafkatest.services.verifiable_producer import VerifiableProducer
 from kafkatest.services.zookeeper import ZookeeperService
 from kafkatest.tests.produce_consume_validate import ProduceConsumeValidateTest
@@ -50,10 +50,10 @@ class TestMigration(ProduceConsumeValidateTest):
 
     def do_migration(self):
         # Start up KRaft controller in migration mode
-        remote_quorum = partial(ServiceQuorumInfo, remote_kraft)
+        remote_quorum = partial(ServiceQuorumInfo, isolated_kraft)
         controller = KafkaService(self.test_context, num_nodes=1, zk=self.zk, 
version=DEV_BRANCH,
                                   allow_zk_with_kraft=True,
-                                  remote_kafka=self.kafka,
+                                  isolated_kafka=self.kafka,
                                   server_prop_overrides=[["zookeeper.connect", 
self.zk.connect_setting()],
                                                          
["zookeeper.metadata.migration.enable", "true"]],
                                   quorum_info_provider=remote_quorum)