This is an automated email from the ASF dual-hosted git repository.
lianetm pushed a commit to branch 4.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/4.0 by this push:
new f181048e426 [MINOR] Cleaning ignored streams test (#20584)
f181048e426 is described below
commit f181048e42649a7ab3d6a73bf0ccb09a001edac2
Author: Genseric Ghiro <[email protected]>
AuthorDate: Wed Oct 1 13:40:00 2025 -0400
[MINOR] Cleaning ignored streams test (#20584)
This test has been disabled for years + it tests ZK setup, but with
KRaft there is no more a "controller", so cleaning it up.
---
.../tests/streams/streams_broker_bounce_test.py | 25 ----------------------
1 file changed, 25 deletions(-)
diff --git a/tests/kafkatest/tests/streams/streams_broker_bounce_test.py
b/tests/kafkatest/tests/streams/streams_broker_bounce_test.py
index dc61e5fa37c..05d57733be6 100644
--- a/tests/kafkatest/tests/streams/streams_broker_bounce_test.py
+++ b/tests/kafkatest/tests/streams/streams_broker_bounce_test.py
@@ -17,7 +17,6 @@ from ducktape.utils.util import wait_until
from ducktape.tests.test import Test
from ducktape.mark.resource import cluster
from ducktape.mark import matrix
-from ducktape.mark import ignore
from kafkatest.services.kafka import KafkaService, quorum
from kafkatest.services.streams import StreamsSmokeTestDriverService,
StreamsSmokeTestJobRunnerService
import time
@@ -225,30 +224,6 @@ class StreamsBrokerBounceTest(Test):
return self.collect_results(sleep_time_secs)
- @ignore
- @cluster(num_nodes=7)
- @matrix(failure_mode=["clean_shutdown"],
- broker_type=["controller"],
- sleep_time_secs=[0],
- metadata_quorum=[quorum.combined_kraft])
- def test_broker_type_bounce_at_start(self, failure_mode, broker_type,
sleep_time_secs, metadata_quorum):
- """
- Start a smoke test client, then kill one particular broker immediately
before streams stats
- Streams should throw an exception since it cannot create topics with
the desired
- replication factor of 3
- """
- self.setup_system(start_processor=False)
-
- # Sleep to allow test to run for a bit
- time.sleep(sleep_time_secs)
-
- # Fail brokers
- self.fail_broker_type(failure_mode, broker_type)
-
- self.processor1.start()
-
- return self.collect_results(sleep_time_secs)
-
@cluster(num_nodes=10)
@matrix(failure_mode=["clean_shutdown", "hard_shutdown", "clean_bounce",
"hard_bounce"],
num_failures=[2],
