diff --git a/Kafka/Consumer.php b/Kafka/Consumer.php
index aaa0b12c..108058eb 100644
--- a/Kafka/Consumer.php
+++ b/Kafka/Consumer.php
@@ -14,16 +14,18 @@
 
 namespace Kafka;
 
+use function Amp\run;
+
 /**
-+------------------------------------------------------------------------------
+ * +------------------------------------------------------------------------------
 * Kafka protocol since Kafka v0.8
-+------------------------------------------------------------------------------
+* +------------------------------------------------------------------------------
 *
 * @package
 * @version $_SWANBR_VERSION_$
 * @copyright Copyleft
 * @author $_SWANBR_AUTHOR_$
-+------------------------------------------------------------------------------
+* +------------------------------------------------------------------------------
 */
 
 class Consumer
@@ -73,6 +75,7 @@ class Consumer
         }
         $process->start();
         $this->isRunning = true;
+        run();
     }
 
     // }}}