From ceec218351ff741dc338edf8d3810c1f36555e33 Mon Sep 17 00:00:00 2001 From: vamossagar12 Date: Tue, 25 Jun 2024 22:06:04 +0530 Subject: [PATCH] KAFKA-16949: Fixing test_dynamic_logging in system test connect_distributed_test (#15915) Reviewers: Chris Egerton --- tests/kafkatest/tests/connect/connect_distributed_test.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tests/kafkatest/tests/connect/connect_distributed_test.py b/tests/kafkatest/tests/connect/connect_distributed_test.py index a244d7e6846..18c97254f1a 100644 --- a/tests/kafkatest/tests/connect/connect_distributed_test.py +++ b/tests/kafkatest/tests/connect/connect_distributed_test.py @@ -21,7 +21,7 @@ from ducktape.cluster.remoteaccount import RemoteCommandError from kafkatest.services.zookeeper import ZookeeperService from kafkatest.services.kafka import KafkaService, config_property, quorum, consumer_group -from kafkatest.services.connect import ConnectDistributedService, VerifiableSource, VerifiableSink, ConnectRestError, MockSink, MockSource +from kafkatest.services.connect import ConnectDistributedService, ConnectServiceBase, VerifiableSource, VerifiableSink, ConnectRestError, MockSink, MockSource from kafkatest.services.console_consumer import ConsoleConsumer from kafkatest.services.security.security_config import SecurityConfig from kafkatest.version import DEV_BRANCH, LATEST_2_3, LATEST_2_2, LATEST_2_1, LATEST_2_0, LATEST_1_1, LATEST_1_0, LATEST_0_11_0, LATEST_0_10_2, LATEST_0_10_1, LATEST_0_10_0, LATEST_0_9, LATEST_0_8_2, KafkaVersion @@ -468,7 +468,7 @@ class ConnectDistributedTest(Test): self.setup_services(num_workers=3) self.cc.set_configs(lambda node: self.render("connect-distributed.properties", node=node)) - self.cc.start() + self.cc.start(mode=ConnectServiceBase.STARTUP_MODE_JOIN) worker = self.cc.nodes[0] initial_loggers = self.cc.get_all_loggers(worker)