diff --git a/Kafka/Broker.php b/Kafka/Broker.php
index 3e26247b..1af997ef 100644
--- a/Kafka/Broker.php
+++ b/Kafka/Broker.php
@@ -189,7 +189,7 @@ class Broker
 //                if (!$modeSync) {
 //                    $socket->SetonReadable($this->process);
 //                }
-//                $socket->connect();
+                $socket->connect();
                 $this->{$type}[$key] = $socket;
                 return $socket;
             } catch (\Exception $e) {