Merge pull request #132 from noname007/master

return after reconnect
weiboad · Oct 20, 2017 · 16b8a7b · 16b8a7b
2 parents b5ac153 + 08d8a31
commit 16b8a7b
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);