Merge pull request #504 from bf2fc6cc711aee1a0c2a/timeout-investigations

add skip test exception if too many instances being created during wa…

Author: henryZrncik

src/test/java/io/managed/services/test/cluster/DataPlaneClusterTest.java

@@ -409,6 +409,22 @@ public void testReportedCapacityMatchesNumberOfExistingInstances(ManagedKafkaTyp
                         log.debug("newly observed remaining capacity '{}'", newlyObservedRemainingCapacity);
                         if (newlyObservedRemainingCapacity > remainingCapacityBefore)
                             return true;
+
+                        // see if any new instance of given type was created, if so don't expect capacity to be increased
+                        List<String> currentKafkaInstances = FleetshardUtils.listManagedKafka(oc, mkType).stream()
+                                .map(e -> e.getMetadata().getName())
+                                .collect(Collectors.toList());
+                        // filter: keep instances that did not existed previously, and filter instance that we created
+                        List<String> instancesCreatedDuringFreeingCapacity = currentKafkaInstances.stream()
+                                .filter(e -> !kafkaInstanceNamesBeforeCreating.contains(e))
+                                .collect(Collectors.toList());
+                        log.debug("count of instances that have been created since begging of waiting for freeing capacity {}", instancesCreatedDuringFreeingCapacity.size());
+                        log.debug(instancesCreatedDuringFreeingCapacity);
+
+                        if (instancesCreatedDuringFreeingCapacity.size() > 1)
+                            throw new SkipException("Instances created during waiting for freeing capacity, no longer possible to observe freeing capacity");
+
+                        // continue waiting
                         return false;
                     });