#65 Debug /opt/kafka/config/ not writable

eventuate-foundation · Aug 20, 2024 · 1fc2554 · 1fc2554
1 parent 2712d1d
commit 1fc2554
Showing 1 changed file with 11 additions and 3 deletions.
diff --git a/.../main/java/io/eventuate/messaging/kafka/testcontainers/EventuateKafkaNativeContainer.java b/.../main/java/io/eventuate/messaging/kafka/testcontainers/EventuateKafkaNativeContainer.java
@@ -45,12 +45,20 @@ public void registerProperties(BiConsumer<String, Supplier<Object>> registry) {
     protected void containerIsStarting(InspectContainerResponse containerInfo) {
         try {
             ExecResult result = execInContainer("ls", "-ltd", "/opt/kafka/config/");
-            System.out.println("ls -ltd /opt/kafka/config/: " + result.getExitCode());
-            System.out.println("ls -ltd /opt/kafka/config/: " + result.getStdout());
-            System.out.println("ls -ltd /opt/kafka/config/: " + result.getStderr());
+            printExecResult(result, "ls -ltd /opt/kafka/config/: ");
+            result = execInContainer("whoami");
+            printExecResult(result, "whoami");
+            result = execInContainer("touch", "/opt/kafka/config/foo");
+            printExecResult(result, "touch /opt/kafka/config/foo");
         } catch (IOException | InterruptedException e) {
             throw new RuntimeException(e);
         }
         super.containerIsStarting(containerInfo);
     }
+
+    private static void printExecResult(ExecResult result, String command) {
+        System.out.println(command + result.getExitCode());
+        System.out.println(command + result.getStdout());
+        System.out.println(command + result.getStderr());
+    }
 }