diff --git a/Kafka/Consumer.php b/Kafka/Consumer.php
index 180e3edc..faa1a635 100644
--- a/Kafka/Consumer.php
+++ b/Kafka/Consumer.php
@@ -74,7 +74,7 @@ class Consumer
         $process->start();
         $this->isRunning = true;
         if ($isBlock) {
-//            \Amp\run();
+            \Amp\run();
         }
     }