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

diff --git a/Kafka/SocketSync.php b/Kafka/SocketSync.php
index 6b0bafd1..d66bd6d9 100644
--- a/Kafka/SocketSync.php
+++ b/Kafka/SocketSync.php
@@ -14,6 +14,8 @@
 
 namespace Kafka;
 
+use Snowflake\Event;
+use Snowflake\Snowflake;
 use Swoole\Coroutine\Client;
 
 /**
@@ -342,6 +344,11 @@ class SocketSync
 		$failedWriteAttempts = 0;
 		$written = 0;
 		$buflen = strlen($buf);
+
+
+		$event = Snowflake::app()->getEvent();
+		$event->on(Event::EVENT_AFTER_REQUEST, [$this, 'close']);
+
 		while ($written < $buflen) {
 			if ($buflen - $written > self::MAX_WRITE_BUFFER) {
 				// write max buffer size