diff --git a/eventuate-messaging-kafka-testcontainers/src/main/java/io/eventuate/messaging/kafka/testcontainers/EventuateKafkaNativeContainer.java b/eventuate-messaging-kafka-testcontainers/src/main/java/io/eventuate/messaging/kafka/testcontainers/EventuateKafkaNativeContainer.java
index 9d3cdd2..a120e54 100644
--- a/eventuate-messaging-kafka-testcontainers/src/main/java/io/eventuate/messaging/kafka/testcontainers/EventuateKafkaNativeContainer.java
+++ b/eventuate-messaging-kafka-testcontainers/src/main/java/io/eventuate/messaging/kafka/testcontainers/EventuateKafkaNativeContainer.java
@@ -54,8 +54,8 @@ protected void containerIsStarting(InspectContainerResponse containerInfo) {
             printExecResult(result, "id");
             result = execInContainer("touch", "/opt/kafka/config/foo");
             printExecResult(result, "touch /opt/kafka/config/foo");
-            result = execInContainer("sh", "-c", "[[ -w /opt/kafka/config/ ]] && echo yes");
-            printExecResult(result, "sh -c '[[ -w /opt/kafka/config/ ]] && echo yes'");
+            result = execInContainer("bash", "-c", "[[ -w /opt/kafka/config/ ]] && echo yes");
+            printExecResult(result, "bash -c '[[ -w /opt/kafka/config/ ]] && echo yes'");
         } catch (IOException | InterruptedException e) {
             throw new RuntimeException(e);
         }