diff --git a/src/main/java/io/strimzi/test/container/StrimziKafkaCluster.java b/src/main/java/io/strimzi/test/container/StrimziKafkaCluster.java index 8ae64f1..4ad2fae 100644 --- a/src/main/java/io/strimzi/test/container/StrimziKafkaCluster.java +++ b/src/main/java/io/strimzi/test/container/StrimziKafkaCluster.java @@ -392,7 +392,7 @@ public void start() { Startables.deepStart(startables).get(60, TimeUnit.SECONDS); } catch (InterruptedException | ExecutionException | TimeoutException e) { Thread.currentThread().interrupt(); - e.printStackTrace(); + throw new RuntimeException("Failed to start Kafka containers", e); } if (this.isZooKeeperBasedKafkaCluster()) { @@ -411,8 +411,7 @@ public void start() { return brokers != null && brokers.split(",").length == this.brokersNum; } catch (IOException | InterruptedException e) { Thread.currentThread().interrupt(); - e.printStackTrace(); - return false; + throw new RuntimeException("Failed to execute command in ZooKeeper container", e); } }); } else if (this.isKraftKafkaCluster()) {