From 0709bb511dc38016b7f93719095d8c5052e18bce Mon Sep 17 00:00:00 2001 From: Bruno Cadonna Date: Wed, 22 Apr 2020 17:43:38 +0200 Subject: [PATCH] HOTFIX: Fix broker bounce system tests --- tests/kafkatest/tests/streams/streams_broker_bounce_test.py | 2 +- tests/kafkatest/tests/streams/streams_upgrade_test.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/tests/kafkatest/tests/streams/streams_broker_bounce_test.py b/tests/kafkatest/tests/streams/streams_broker_bounce_test.py index a20eb02f9ad44..69f72d2a07e3b 100644 --- a/tests/kafkatest/tests/streams/streams_broker_bounce_test.py +++ b/tests/kafkatest/tests/streams/streams_broker_bounce_test.py @@ -164,7 +164,7 @@ def setup_system(self, start_processor=True, num_threads=3): # Start test harness self.driver = StreamsSmokeTestDriverService(self.test_context, self.kafka) - self.processor1 = StreamsSmokeTestJobRunnerService(self.test_context, self.kafka, num_threads) + self.processor1 = StreamsSmokeTestJobRunnerService(self.test_context, self.kafka, "at_least_once", num_threads) self.driver.start() diff --git a/tests/kafkatest/tests/streams/streams_upgrade_test.py b/tests/kafkatest/tests/streams/streams_upgrade_test.py index 662f141ce9b51..1d00d90313a83 100644 --- a/tests/kafkatest/tests/streams/streams_upgrade_test.py +++ b/tests/kafkatest/tests/streams/streams_upgrade_test.py @@ -152,7 +152,7 @@ def test_upgrade_downgrade_brokers(self, from_version, to_version): self.driver = StreamsSmokeTestDriverService(self.test_context, self.kafka) - processor = StreamsSmokeTestJobRunnerService(self.test_context, self.kafka) + processor = StreamsSmokeTestJobRunnerService(self.test_context, self.kafka, "at_least_once") with self.driver.node.account.monitor_log(self.driver.STDOUT_FILE) as driver_monitor: self.driver.start()