update operations test

Author: razvan

tests/templates/kuttl/operations-kraft/60-assert.yaml.j2

@@ -17,5 +17,5 @@ kind: StatefulSet
 metadata:
   name: test-kafka-controller-default
 status:
-  readyReplicas: 1
-  replicas: 1
+  readyReplicas: 5
+  replicas: 5

…s-kraft/60-scale-controller-down.yaml.j2 …ons-kraft/60-scale-controller-up.yaml.j2tests/templates/kuttl/operations-kraft/60-scale-controller-down.yaml.j2 renamed to tests/templates/kuttl/operations-kraft/60-scale-controller-up.yaml.j2 tests/templates/kuttl/operations-kraft/60-scale-controller-down.yaml.j2 renamed to tests/templates/kuttl/operations-kraft/60-scale-controller-up.yaml.j2

@@ -25,7 +25,7 @@ spec:
         enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}
     roleGroups:
       default:
-        replicas: 1
+        replicas: 5
   brokers:
     config:
       logging:

tests/templates/kuttl/operations-kraft/70-assert.yaml.j2

@@ -0,0 +1,21 @@
+---
+apiVersion: kuttl.dev/v1beta1
+kind: TestAssert
+timeout: 300
+commands:
+  - script: kubectl -n $NAMESPACE wait --for=condition=available kafkaclusters.kafka.stackable.tech/test-kafka --timeout 301s
+---
+apiVersion: apps/v1
+kind: StatefulSet
+metadata:
+  name: test-kafka-broker-default
+status:
+  readyReplicas: 3
+  replicas: 3
+apiVersion: apps/v1
+kind: StatefulSet
+metadata:
+  name: test-kafka-controller-default
+status:
+  readyReplicas: 3
+  replicas: 3

tests/templates/kuttl/operations-kraft/70-scale-controller-down.yaml.j2

@@ -0,0 +1,38 @@
+---
+apiVersion: kuttl.dev/v1beta1
+kind: TestStep
+timeout: 300
+---
+apiVersion: kafka.stackable.tech/v1alpha1
+kind: KafkaCluster
+metadata:
+  name: test-kafka
+spec:
+  image:
+{% if test_scenario['values']['kafka-kraft'].find(",") > 0 %}
+    custom: "{{ test_scenario['values']['kafka-kraft'].split(',')[1] }}"
+    productVersion: "{{ test_scenario['values']['kafka-kraft'].split(',')[0] }}"
+{% else %}
+    productVersion: "{{ test_scenario['values']['kafka-kraft'] }}"
+{% endif %}
+{% if lookup('env', 'VECTOR_AGGREGATOR') %}
+  clusterConfig:
+    vectorAggregatorConfigMapName: vector-aggregator-discovery
+{% endif %}
+  controllers:
+    config:
+      logging:
+        enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}
+    roleGroups:
+      default:
+        replicas: 3
+  brokers:
+    config:
+      logging:
+        enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}
+    roleGroups:
+      default:
+        replicas: 3
+  clusterOperation:
+    stopped: false
+    reconciliationPaused: false

tests/templates/kuttl/operations-kraft/README.md

@@ -4,3 +4,10 @@ Tests Kraft cluster operations:
 - Cluster stop/pause/restart
 - Scale brokers up/down
 - Scale controllers up/down
+
+TODO:
+
+- Scaling controllers from 3 -> 1 doesn't work.
+  Both brokers and controllers try to communicate with old controllers.
+  This is why, the last step scales from 5 -> 3 controllers.
+  This at least, leaves the cluster in a working state.