diff --git a/src/Util/KafkaUtil.php b/src/Util/KafkaUtil.php
index 5ad3524..19b47de 100644
--- a/src/Util/KafkaUtil.php
+++ b/src/Util/KafkaUtil.php
@@ -66,6 +66,7 @@ public static function retry(ClientInterface $client, AbstractRequest $request,
         }
         $errorCode = $response->getErrorCode();
         if (!ErrorCode::success($errorCode)) {
+            $client->close();
             if ($retry > 0 && ErrorCode::canRetry($errorCode)) {
                 if ($sleep > 0) {
                     usleep((int) ($sleep * 1000000));