From 3d62ec2c72104cde1baced642c2e31ea26852f34 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mr=C2=B7x?= <as2252258@163.com>
Date: Sat, 10 Oct 2020 10:56:42 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Kafka/SocketSync.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/Kafka/SocketSync.php b/Kafka/SocketSync.php
index 8d296c2e..bbe07169 100644
--- a/Kafka/SocketSync.php
+++ b/Kafka/SocketSync.php
@@ -273,7 +273,7 @@ class SocketSync
 		if ($len > self::READ_MAX_LEN) {
 			throw new Exception('Could not read ' . $len . ' bytes from stream, length too longer.');
 		}
-		$stream = Context::getContext(self::SOCKET_NAME);
+		$stream = $this->connect();
 
 		$null = null;
 		$remainingBytes = $len;