Move duplicated code into KCatContainer

Author: julianladisch

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

@@ -195,13 +195,8 @@ public void testUsageWithListener() throws Exception {
                 .withNetwork(network);
             // }
             // createKCatContainer {
-            GenericContainer<?> kcat = new GenericContainer<>("confluentinc/cp-kcat:7.9.0")
-                .withCreateContainerCmdModifier(cmd -> {
-                    cmd.withEntrypoint("sh");
-                })
-                .withCopyToContainer(Transferable.of("Message produced by kcat"), "/data/msgs.txt")
+            KCatContainer kcat = new KCatContainer()
                 .withNetwork(network)
-                .withCommand("-c", "tail -f /dev/null")
             // }
         ) {
             kafka.start();

modules/redpanda/src/test/java/org/testcontainers/redpanda/KCatContainer.java

@@ -0,0 +1,16 @@
+package org.testcontainers;
+
+import org.testcontainers.containers.GenericContainer;
+import org.testcontainers.images.builder.Transferable;
+
+public class KCatContainer extends GenericContainer<KCatContainer> {
+
+    public KCatContainer() {
+        super("confluentinc/cp-kcat:7.9.0");
+        withCreateContainerCmdModifier(cmd -> {
+            cmd.withEntrypoint("sh");
+        });
+        withCopyToContainer(Transferable.of("Message produced by kcat"), "/data/msgs.txt");
+        withCommand("-c", "tail -f /dev/null");
+    }
+}

modules/redpanda/src/test/java/org/testcontainers/redpanda/RedpandaContainerTest.java

@@ -111,13 +111,8 @@ public void testUsageWithListener() throws Exception {
             RedpandaContainer redpanda = new RedpandaContainer("docker.redpanda.com/redpandadata/redpanda:v23.1.7")
                 .withListener(() -> "redpanda:19092")
                 .withNetwork(network);
-            GenericContainer<?> kcat = new GenericContainer<>("confluentinc/cp-kcat:7.9.0")
-                .withCreateContainerCmdModifier(cmd -> {
-                    cmd.withEntrypoint("sh");
-                })
-                .withCopyToContainer(Transferable.of("Message produced by kcat"), "/data/msgs.txt")
+            KCatContainer kcat = new KCatContainer()
                 .withNetwork(network)
-                .withCommand("-c", "tail -f /dev/null")
         ) {
             redpanda.start();
             kcat.start();
@@ -141,13 +136,8 @@ public void testUsageWithListenerInTheSameNetwork() throws Exception {
                 .withNetwork(network);
             // }
             // createKCatContainer {
-            GenericContainer<?> kcat = new GenericContainer<>("confluentinc/cp-kcat:7.9.0")
-                .withCreateContainerCmdModifier(cmd -> {
-                    cmd.withEntrypoint("sh");
-                })
-                .withCopyToContainer(Transferable.of("Message produced by kcat"), "/data/msgs.txt")
+            KCatContainer kcat = new KCatContainer()
                 .withNetwork(network)
-                .withCommand("-c", "tail -f /dev/null")
             // }
         ) {
             kafka.start();
@@ -200,13 +190,8 @@ public void testUsageWithListenerAndSasl() throws Exception {
                 .withSuperuser("panda")
                 .withListener("my-panda:29092")
                 .withNetwork(network);
-            GenericContainer<?> kcat = new GenericContainer<>("confluentinc/cp-kcat:7.9.0")
-                .withCreateContainerCmdModifier(cmd -> {
-                    cmd.withEntrypoint("sh");
-                })
-                .withCopyToContainer(Transferable.of("Message produced by kcat"), "/data/msgs.txt")
+            KCatContainer kcat = new KCatContainer()
                 .withNetwork(network)
-                .withCommand("-c", "tail -f /dev/null")
         ) {
             redpanda.start();