Remove debug code

testcontainers · Nov 11, 2019 · 95b28d7 · 95b28d7
1 parent f0a3dd3
commit 95b28d7
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/modules/kafka/src/main/java/org/testcontainers/containers/KafkaContainerCluster.java b/modules/kafka/src/main/java/org/testcontainers/containers/KafkaContainerCluster.java
@@ -98,10 +98,7 @@ public void start() {
 
         Unreliables.retryUntilTrue(30, TimeUnit.SECONDS, () -> this.brokers.stream().findFirst()
                 .map(this::clusterBrokers)
-                .filter(brokers -> {
-                    System.out.println("Found broker str: " + brokers);
-                    return brokers.split(",").length == this.brokersNum;
-                })
+                .filter(brokers -> brokers.split(",").length == this.brokersNum)
                 .isPresent());
     }