|
17 | 17 | from ducktape.tests.test import Test
|
18 | 18 | from ducktape.mark.resource import cluster
|
19 | 19 | from ducktape.mark import matrix
|
20 |
| -from ducktape.mark import ignore |
21 | 20 | from kafkatest.services.kafka import KafkaService, quorum
|
22 | 21 | from kafkatest.services.streams import StreamsSmokeTestDriverService, StreamsSmokeTestJobRunnerService
|
23 | 22 | import time
|
@@ -225,30 +224,6 @@ def test_broker_type_bounce(self, failure_mode, broker_type, sleep_time_secs, nu
|
225 | 224 |
|
226 | 225 | return self.collect_results(sleep_time_secs)
|
227 | 226 |
|
228 |
| - @ignore |
229 |
| - @cluster(num_nodes=7) |
230 |
| - @matrix(failure_mode=["clean_shutdown"], |
231 |
| - broker_type=["controller"], |
232 |
| - sleep_time_secs=[0], |
233 |
| - metadata_quorum=[quorum.combined_kraft]) |
234 |
| - def test_broker_type_bounce_at_start(self, failure_mode, broker_type, sleep_time_secs, metadata_quorum): |
235 |
| - """ |
236 |
| - Start a smoke test client, then kill one particular broker immediately before streams stats |
237 |
| - Streams should throw an exception since it cannot create topics with the desired |
238 |
| - replication factor of 3 |
239 |
| - """ |
240 |
| - self.setup_system(start_processor=False) |
241 |
| - |
242 |
| - # Sleep to allow test to run for a bit |
243 |
| - time.sleep(sleep_time_secs) |
244 |
| - |
245 |
| - # Fail brokers |
246 |
| - self.fail_broker_type(failure_mode, broker_type) |
247 |
| - |
248 |
| - self.processor1.start() |
249 |
| - |
250 |
| - return self.collect_results(sleep_time_secs) |
251 |
| - |
252 | 227 | @cluster(num_nodes=10)
|
253 | 228 | @matrix(failure_mode=["clean_shutdown", "hard_shutdown", "clean_bounce", "hard_bounce"],
|
254 | 229 | num_failures=[2],
|
|
0 commit comments