diff --git a/kroxylicious-systemtests/src/main/java/io/kroxylicious/systemtests/installation/kroxylicious/KroxyliciousApp.java b/kroxylicious-systemtests/src/main/java/io/kroxylicious/systemtests/installation/kroxylicious/KroxyliciousApp.java index c78b658f1a..681a9134dd 100644 --- a/kroxylicious-systemtests/src/main/java/io/kroxylicious/systemtests/installation/kroxylicious/KroxyliciousApp.java +++ b/kroxylicious-systemtests/src/main/java/io/kroxylicious/systemtests/installation/kroxylicious/KroxyliciousApp.java @@ -13,8 +13,8 @@ import java.nio.file.Files; import java.nio.file.Path; import java.util.Iterator; -import java.util.concurrent.TimeUnit; import java.util.Optional; +import java.util.concurrent.TimeUnit; import java.util.stream.Stream; import org.slf4j.Logger; @@ -99,9 +99,9 @@ public String getBootstrap() { String clusterIP = null; try { var nis = NetworkInterface.getNetworkInterfaces(); - for (Iterator it = nis.asIterator(); it.hasNext(); ) { + for (Iterator it = nis.asIterator(); it.hasNext();) { var ni = it.next(); - for (Iterator iter = ni.getInetAddresses().asIterator(); iter.hasNext(); ) { + for (Iterator iter = ni.getInetAddresses().asIterator(); iter.hasNext();) { var i = iter.next(); if (i.getHostAddress().startsWith("10")) { clusterIP = i.getHostAddress(); @@ -137,4 +137,4 @@ public void stop() { thread.interrupt(); ProcessHandle.of(pid).ifPresent(ProcessHandle::destroy); } -} \ No newline at end of file +} diff --git a/kroxylicious-systemtests/src/main/java/io/kroxylicious/systemtests/utils/KafkaUtils.java b/kroxylicious-systemtests/src/main/java/io/kroxylicious/systemtests/utils/KafkaUtils.java index 1676dd1fa2..59303090cf 100644 --- a/kroxylicious-systemtests/src/main/java/io/kroxylicious/systemtests/utils/KafkaUtils.java +++ b/kroxylicious-systemtests/src/main/java/io/kroxylicious/systemtests/utils/KafkaUtils.java @@ -96,7 +96,7 @@ public static String ConsumeMessageWithTestClients(String deployNamespace, Strin kubeClient().getClient().load(file).inNamespace(deployNamespace).create(); String podName = getPodNameByLabel(deployNamespace, "app", Constants.KAFKA_CONSUMER_CLIENT_LABEL, timeoutMilliseconds); await().atMost(Duration.ofMillis(timeoutMilliseconds)).until(() -> { - if (kubeClient().getClient().pods().inNamespace(deployNamespace).withName(podName).get() != null ) { + if (kubeClient().getClient().pods().inNamespace(deployNamespace).withName(podName).get() != null) { var log = kubeClient().logsInSpecificNamespace(deployNamespace, podName); return log.contains(" - " + (numOfMessages - 1)); }