From 39dfdaf9634b5685c978658edc9918928a1a6644 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mr=2E=E5=94=90?= <tw2066@163.com>
Date: Thu, 3 Apr 2025 22:10:53 +0800
Subject: [PATCH] Update KafkaUtil.php

[WARNING] [AbstractProcess@anonymous\/vendor/hyperf/kafka/src/ConsumerManager.php:81$16a::handle] longlang\phpkafka\Exception\KafkaErrorException: [25] The coordinator is not aware of this member. in vendor/longlang/phpkafka/src/Protocol/ErrorCode.php:385
---
 src/Util/KafkaUtil.php | 1 +
 1 file changed, 1 insertion(+)

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));