diff --git a/kafka-demo.groovy b/kafka-demo.groovy
index a551161..894990b 100644
--- a/kafka-demo.groovy
+++ b/kafka-demo.groovy
@@ -24,11 +24,11 @@
     stage("Enforce kubernetes.control") {
         common.infoMsg('Enforcing kubernetes.control on I@kubernetes:master')
 
-        salt.enforceState(
+        salt.runSaltProcessStep(
             master,
-            ['expression': 'I@kubernetes:master', 'type': 'compound'],
+            'I@kubernetes:master',
+            'state.sls',
             ['kubernetes.control'],
-            true
         )
     }