format

Author: julianladisch

modules/kafka/src/test/java/org/testcontainers/AbstractKafka.java

@@ -159,12 +159,9 @@ protected void assertKafka(String listener, Network network) {
             kcat.start();
 
             kcat.execInContainer("kcat", "-b", listener, "-t", "msgs", "-P", "-l", "/data/msgs.txt");
-            String stdout = kcat
-                    .execInContainer("kcat", "-b", listener, "-C", "-t", "msgs", "-c", "1")
-                    .getStdout();
+            String stdout = kcat.execInContainer("kcat", "-b", listener, "-C", "-t", "msgs", "-c", "1").getStdout();
 
             assertThat(stdout).contains("Message produced by kcat");
         }
     }
-
 }

modules/kafka/src/test/java/org/testcontainers/kafka/ConfluentKafkaContainerTest.java

@@ -9,8 +9,6 @@
 import org.testcontainers.containers.SocatContainer;
 import org.testcontainers.utility.MountableFile;
 
-import static org.assertj.core.api.Assertions.assertThat;
-
 public class ConfluentKafkaContainerTest extends AbstractKafka {
 
     @Test

modules/kafka/src/test/java/org/testcontainers/kafka/KafkaContainerTest.java

@@ -21,13 +21,13 @@ public void testUsage() throws Exception {
     @Test
     public void testUsageWithNetworkAlias() {
         try (
-                // registerAlias {
-                Network network = Network.newNetwork();
-                KafkaContainer kafka = new KafkaContainer("apache/kafka-native:3.8.0")
-                        .withNetworkAliases("kafka")
-                        .withNetwork(network);
-                // }
-                ) {
+            // registerAlias {
+            Network network = Network.newNetwork();
+            KafkaContainer kafka = new KafkaContainer("apache/kafka-native:3.8.0")
+                .withNetworkAliases("kafka")
+                .withNetwork(network);
+            // }
+        ) {
             kafka.start();
             assertKafka("kafka:9092", network);
         }