diff --git a/Kafka/Consumer.php b/Kafka/Consumer.php
index faa1a635..180e3edc 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();
         }
     }