[WIP] add test

Signed-off-by: jkalinic <[email protected]>

Author: jankalinic

systemtests/src/main/java/com/github/streamshub/systemtests/utils/WaitUtils.java

@@ -509,11 +509,11 @@ public static void waitForLogInPod(String namespace, String podName, String expe
     }
 
     public static void waitForKafkaRebalanceProposalStatus(String namespace, String rebalanceName, KafkaRebalanceState kafkaRebalanceState) {
-        Wait.until(String.format("KafkaRabalance %s/%s to be in state [%s]", namespace, rebalanceName, kafkaRebalanceState),
+        Wait.until(String.format("KafkaRebalance %s/%s to be in state [%s]", namespace, rebalanceName, kafkaRebalanceState),
             TestFrameConstants.GLOBAL_POLL_INTERVAL_MEDIUM, TestFrameConstants.GLOBAL_TIMEOUT_MEDIUM,
             () -> {
-                 KafkaRebalance rebalance = ResourceUtils.getKubeResource(KafkaRebalance.class, namespace, rebalanceName);
-                 return rebalance != null && rebalance.getStatus() != null &&
+                KafkaRebalance rebalance = ResourceUtils.getKubeResource(KafkaRebalance.class, namespace, rebalanceName);
+                return rebalance != null && rebalance.getStatus() != null &&
                     rebalance.getStatus().getConditions().stream()
                         .filter(c -> c.getType().equals(kafkaRebalanceState.name()))
                         .map(c -> c.getStatus().equals("True"))

systemtests/src/test/java/com/github/streamshub/systemtests/kafka/RebalanceST.java

@@ -78,6 +78,7 @@ void testKafkaRebalance() {
         PwUtils.waitForLocatorAndClick(tcc, NodesPageSelectors.NPS_PROPOSAL_ACTION_APPROVE_BUTTON);
         PwUtils.waitForLocatorAndClick(tcc, NodesPageSelectors.NPS_PROPOSAL_MODAL_CONFIRM_BUTTON);
 
+        LOGGER.info("Verify that UI caused rebalancing");
         WaitUtils.waitForKafkaRebalanceProposalStatus(tcc.namespace(), rebalanceName, KafkaRebalanceState.Rebalancing);
         PwUtils.waitForContainsText(tcc, NodesPageSelectors.NPS_REBALANCE_PROPOSAL_STATUS, KafkaRebalanceState.Rebalancing.name(), true);
     }