diff --git a/src/run.ts b/src/run.ts
index 72b3ef15c..003e186ae 100644
--- a/src/run.ts
+++ b/src/run.ts
@@ -161,10 +161,9 @@ async function deploy(options: { stage: string }) {
   const deployCmd = ["sls", "deploy", "--stage", stage];
   await runner.run_command_and_output("SLS Deploy", deployCmd, ".");
   // Only deploy resources for kafka ingestion in real envs
-
-  // if (stage === "main" || stage === "val" || stage === "production") {
-  await deploy_kafka_service(runner, stage);
-  // }
+  if (stage === "main" || stage === "val" || stage === "production") {
+    await deploy_kafka_service(runner, stage);
+  }
 }
 
 async function destroy_stage(options: {