Skip to content

Commit 48bf47c

Browse files
committed
re-enable downscale tests and ensure clean ns termination
1 parent fa1f7ef commit 48bf47c

File tree

4 files changed

+67
-4
lines changed

4 files changed

+67
-4
lines changed
Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,3 @@
1-
#
2-
# This test step is disabled becaus Kraft controller do scale down reliably.
3-
# This leads to flaky tests.
4-
#
51
{% if not test_scenario['values']['kafka-kraft'].startswith("3.7") %}
62
---
73
apiVersion: kuttl.dev/v1beta1
Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
{% if not test_scenario['values']['kafka-kraft'].startswith("3.7") %}
2+
---
3+
apiVersion: kuttl.dev/v1beta1
4+
kind: TestAssert
5+
timeout: 600
6+
---
7+
apiVersion: apps/v1
8+
kind: StatefulSet
9+
metadata:
10+
name: test-kafka-broker-default
11+
status:
12+
replicas: 0
13+
---
14+
apiVersion: apps/v1
15+
kind: StatefulSet
16+
metadata:
17+
name: test-kafka-controller-default
18+
status:
19+
readyReplicas: 3
20+
replicas: 3
21+
{% endif %}
Lines changed: 46 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,46 @@
1+
#
2+
# This is a test helper to ensure that all broker pods are deleted before
3+
# the test namespace is terminated.
4+
# The brokers must be deleted because otherwise they are left dangling until
5+
# the test timeouts and fails.
6+
#
7+
{% if not test_scenario['values']['kafka-kraft'].startswith("3.7") %}
8+
---
9+
apiVersion: kuttl.dev/v1beta1
10+
kind: TestStep
11+
timeout: 600
12+
---
13+
apiVersion: kafka.stackable.tech/v1alpha1
14+
kind: KafkaCluster
15+
metadata:
16+
name: test-kafka
17+
spec:
18+
image:
19+
{% if test_scenario['values']['kafka-kraft'].find(",") > 0 %}
20+
custom: "{{ test_scenario['values']['kafka-kraft'].split(',')[1] }}"
21+
productVersion: "{{ test_scenario['values']['kafka-kraft'].split(',')[0] }}"
22+
{% else %}
23+
productVersion: "{{ test_scenario['values']['kafka-kraft'] }}"
24+
{% endif %}
25+
{% if lookup('env', 'VECTOR_AGGREGATOR') %}
26+
clusterConfig:
27+
vectorAggregatorConfigMapName: vector-aggregator-discovery
28+
{% endif %}
29+
controllers:
30+
config:
31+
logging:
32+
enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}
33+
roleGroups:
34+
default:
35+
replicas: 3
36+
brokers:
37+
config:
38+
logging:
39+
enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}
40+
roleGroups:
41+
default:
42+
replicas: 0
43+
clusterOperation:
44+
stopped: false
45+
reconciliationPaused: false
46+
{% endif %}

0 commit comments

Comments
 (0)