This is an automated email from the ASF dual-hosted git repository. mjsax 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 362d199 HOTFIX: Fix broker bounce system tests (#8532) 362d199 is described below commit 362d199dbe1a36f32fe6192fa8a2be1611a1f292 Author: Bruno Cadonna <br...@confluent.io> AuthorDate: Fri Apr 24 17:49:47 2020 +0200 HOTFIX: Fix broker bounce system tests (#8532) Reviewers: Boyang Chen <boy...@confluent.io>, Matthias J. Sax <matth...@confluent.io> --- 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 a20eb02..69f72d2 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 @@ class StreamsBrokerBounceTest(Test): # 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 662f141..1d00d90 100644 --- a/tests/kafkatest/tests/streams/streams_upgrade_test.py +++ b/tests/kafkatest/tests/streams/streams_upgrade_test.py @@ -152,7 +152,7 @@ class StreamsUpgradeTest(Test): 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()