Update KafkaUtil.php

tw2066 · web-flow · commit 39dfdaf9634b · 2025-04-03T22:10:53.000+08:00
[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
diff --git 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));

Original file line number	Diff line number	Diff line change
`@@ -66,6 +66,7 @@ public static function retry(ClientInterface $client, AbstractRequest $request,`
`66`	`66`	`}`
`67`	`67`	`$errorCode = $response->getErrorCode();`
`68`	`68`	`if (!ErrorCode::success($errorCode)) {`
	`69`	`+ $client->close();`
`69`	`70`	`if ($retry > 0 && ErrorCode::canRetry($errorCode)) {`
`70`	`71`	`if ($sleep > 0) {`
`71`	`72`	`usleep((int) ($sleep * 1000000));`