From bda7085deac58c66d365011271ba796be038e4cd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mr=C2=B7x?= <as2252258@163.com>
Date: Fri, 9 Oct 2020 12:02:03 +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 | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/Kafka/SocketSync.php b/Kafka/SocketSync.php
index 584d08b8..6b0bafd1 100644
--- a/Kafka/SocketSync.php
+++ b/Kafka/SocketSync.php
@@ -345,10 +345,10 @@ class SocketSync
 		while ($written < $buflen) {
 			if ($buflen - $written > self::MAX_WRITE_BUFFER) {
 				// write max buffer size
-				$wrote = $this->stream->send(substr($buf, $written, self::MAX_WRITE_BUFFER));
+				$wrote = $this->stream->send(substr($buf, $written, self::MAX_WRITE_BUFFER), 1);
 			} else {
 				// write remaining buffer bytes to stream
-				$wrote = $this->stream->send(substr($buf, $written));
+				$wrote = $this->stream->send(substr($buf, $written), 1);
 			}
 			if ($wrote === -1 || $wrote === false) {
 				throw new \Kafka\Exception\Socket('Could not write ' . strlen($buf) . ' bytes to stream, completed writing only ' . $written . ' bytes');