adding waiting for so-so stability before rolling kafka in kafka node…

… pool ST Signed-off-by: hzrncik <hzrncik@redhat.com>
strimzi · Feb 16, 2024 · d311f3d · d311f3d
1 parent d775517
commit d311f3d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...t/src/main/java/io/strimzi/systemtest/utils/kubeUtils/controllers/StrimziPodSetUtils.java b/...t/src/main/java/io/strimzi/systemtest/utils/kubeUtils/controllers/StrimziPodSetUtils.java
@@ -118,6 +118,7 @@ public static Pod mapToPod(Map<String, Object> map) {
     }
 
     public static void annotateStrimziPodSet(String namespaceName, String resourceName, Map<String, String> annotations) {
+        LOGGER.info("Annotating StrimziPodSet {}/{} with annotations: {}", namespaceName, resourceName, annotations);
         StrimziPodSetResource.replaceStrimziPodSetInSpecificNamespace(resourceName,
             strimziPodSet -> strimziPodSet.getMetadata().setAnnotations(annotations), namespaceName);
     }

diff --git a/systemtest/src/test/java/io/strimzi/systemtest/kafka/KafkaNodePoolST.java b/systemtest/src/test/java/io/strimzi/systemtest/kafka/KafkaNodePoolST.java
@@ -187,6 +187,9 @@ void testNodePoolsRolesChanging() {
         final KafkaTopic kafkaTopic = KafkaTopicTemplates.topic(testStorage.getClusterName(), testStorage.getTopicName(), 1, 6, testStorage.getNamespaceName()).build();
         resourceManager.createResourceWithWait(kafkaTopic);
 
+        LOGGER.info("wait for Kafka pods stability");
+        PodUtils.waitUntilPodStabilityReplicasCount(testStorage.getNamespaceName(), KafkaResource.getStrimziPodSetName(testStorage.getClusterName(), volatileRolePoolName), 3);
+
         LOGGER.info("Start rolling update");
         Map<String, String> volatilePoolPodsSnapshot = PodUtils.podSnapshot(testStorage.getNamespaceName(), volatilePoolLabelSelector);
         StrimziPodSetUtils.annotateStrimziPodSet(testStorage.getNamespaceName(), KafkaResource.getStrimziPodSetName(testStorage.getClusterName(), volatileRolePoolName), Collections.singletonMap(Annotations.ANNO_STRIMZI_IO_MANUAL_ROLLING_UPDATE, "true"));