return after reconnect

weiboad · Oct 17, 2017 · 08d8a31 · 08d8a31
1 parent b5ac153
commit 08d8a31
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/Kafka/Socket.php b/src/Kafka/Socket.php
@@ -252,6 +252,7 @@ public function connect()
                     $newData = @fread($this->stream, self::READ_MAX_LEN);
                 }else{
                     $this->reconnect();
+                    return;
                 }
                 if ($newData) {
                     $this->read($newData);