root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

[MINOR] Cleaning ignored streams test (#20584)
CI / build (push) Has been cancelled Details 

This test has been disabled for years + it tests ZK setup, but with
KRaft there is no more a "controller", so cleaning it up.
This commit is contained in:
Genseric Ghiro 2025-10-01 13:40:00 -04:00 committed by GitHub
parent 8248d1d2bb
commit f181048e42
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
tests/kafkatest/tests/streams/streams_broker_bounce_test.py
View File

@ -17,7 +17,6 @@ from ducktape.utils.util import wait_until
from ducktape.tests.test import Test from ducktape.tests.test import Test
from ducktape.mark.resource import cluster from ducktape.mark.resource import cluster
from ducktape.mark import matrix from ducktape.mark import matrix
from ducktape.mark import ignore
from kafkatest.services.kafka import KafkaService, quorum from kafkatest.services.kafka import KafkaService, quorum
from kafkatest.services.streams import StreamsSmokeTestDriverService, StreamsSmokeTestJobRunnerService from kafkatest.services.streams import StreamsSmokeTestDriverService, StreamsSmokeTestJobRunnerService
import time import time
@ -225,30 +224,6 @@ class StreamsBrokerBounceTest(Test):
return self.collect_results(sleep_time_secs) 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) @cluster(num_nodes=10)
@matrix(failure_mode=["clean_shutdown", "hard_shutdown", "clean_bounce", "hard_bounce"], @matrix(failure_mode=["clean_shutdown", "hard_shutdown", "clean_bounce", "hard_bounce"],
num_failures=[2], num_failures=[2],