diff --git a/Kafka/SocketSync.php b/Kafka/SocketSync.php
index d66bd6d9..58b6b850 100644
--- a/Kafka/SocketSync.php
+++ b/Kafka/SocketSync.php
@@ -254,6 +254,7 @@ class SocketSync
 	{
 		if ($this->stream instanceof \Swoole\Coroutine\Socket) {
 			$this->stream->close();
+			$this->stream = null;
 		}
 	}