From 5ed8c4f597177b81cf1cbc64ede9210fef7adc2e Mon Sep 17 00:00:00 2001 From: Jiamei Xie Date: Wed, 22 Apr 2020 03:16:02 +0000 Subject: [PATCH] KAFKA-9901:Fix streams_broker_bounce_test error The constructor of StreamsSmokeTestJobRunnerService has been changed. But it's not updated in streams_broker_bounce_test.py, which makes num_threads = 3 to be processing_guarantee's value and causes that StreamsTest can't startup Change-Id: I07ebc3e007e0ddd0b5182d5cf9467cdfac993eae Signed-off-by: Jiamei Xie --- tests/kafkatest/tests/streams/streams_broker_bounce_test.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/kafkatest/tests/streams/streams_broker_bounce_test.py b/tests/kafkatest/tests/streams/streams_broker_bounce_test.py index a20eb02f9ad44..08da8a03a60f6 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()