This is an automated email from the ASF dual-hosted git repository.
lianetm pushed a commit to branch 4.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/4.1 by this push:
new ea3d2311851 [MINOR] Cleaning ignored streams test (#20583)
ea3d2311851 is described below
commit ea3d231185133f7935389fa33ede8cd4d9808029
Author: Genseric Ghiro <[email protected]>
AuthorDate: Wed Oct 1 13:39:38 2025 -0400
[MINOR] Cleaning ignored streams test (#20583)
- 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 | 26 ----------------------
1 file changed, 26 deletions(-)
diff --git a/tests/kafkatest/tests/streams/streams_broker_bounce_test.py
b/tests/kafkatest/tests/streams/streams_broker_bounce_test.py
index 3d7e40fdf0d..8ad6facbdf4 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
@@ -229,31 +228,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],
- group_protocol=["classic", "streams"])
- def test_broker_type_bounce_at_start(self, failure_mode, broker_type,
sleep_time_secs, metadata_quorum, group_protocol):
- """
- 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, group_protocol=group_protocol)
-
- # 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],
