From 08d8a31ac24cde7ece476675c74887d17ee64cfb Mon Sep 17 00:00:00 2001
From: soul11201 <soul11201@gmail.com>
Date: Tue, 17 Oct 2017 14:58:22 +0800
Subject: [PATCH] return after reconnect

---
 src/Kafka/Socket.php | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/Kafka/Socket.php b/src/Kafka/Socket.php
index dce0c053..619ffaaa 100644
--- 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);