root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 5 Packages Projects Releases Wiki Activity

KAFKA-16949: Fixing test_dynamic_logging in system test connect_distributed_test (#15915) 

Reviewers: Chris Egerton <chrise@aiven.io>
This commit is contained in:
vamossagar12 2024-06-25 22:06:04 +05:30 committed by GitHub
parent f995edccad
commit ceec218351
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/kafkatest/tests/connect/connect_distributed_test.py
View File

@ -21,7 +21,7 @@ from ducktape.cluster.remoteaccount import RemoteCommandError
from kafkatest.services.zookeeper import ZookeeperService from kafkatest.services.zookeeper import ZookeeperService
from kafkatest.services.kafka import KafkaService, config_property, quorum, consumer_group 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.console_consumer import ConsoleConsumer
from kafkatest.services.security.security_config import SecurityConfig 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 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.setup_services(num_workers=3)
self.cc.set_configs(lambda node: self.render("connect-distributed.properties", node=node)) 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] worker = self.cc.nodes[0]
initial_loggers = self.cc.get_all_loggers(worker) initial_loggers = self.cc.get_all_loggers(worker)