diff --git a/site-modules/profile/manifests/kafka/broker.pp b/site-modules/profile/manifests/kafka/broker.pp
--- a/site-modules/profile/manifests/kafka/broker.pp
+++ b/site-modules/profile/manifests/kafka/broker.pp
@@ -53,12 +53,16 @@
 
   $kafka_logdirs = lookup('kafka::logdirs', Array)
   $kafka_logdirs.each |$logdir| {
-    file {$logdir:
-      ensure  => directory,
-      owner   => 'kafka',
-      group   => 'kafka',
-      mode    => '0750',
-    } -> Service['kafka']
+    exec {"create ${logdir}":
+      creates => $logdir,
+      command => "mkdir -p ${logdir}",
+      path    => ['/bin', '/usr/bin', '/sbin', '/usr/sbin'],
+    } -> file {$logdir:
+      ensure => directory,
+      owner  => 'kafka',
+      group  => 'kafka',
+      mode   => '0750',
+    }
   }
 
   $do_tls = $kafka_cluster_config['tls']