Update KafkaUtil.php

tw2066 · web-flow · commit 46e00a25e082 · 2025-04-03T22:43:12.000+08:00
diff --git a/src/Util/KafkaUtil.php b/src/Util/KafkaUtil.php
@@ -66,7 +66,7 @@ public static function retry(ClientInterface $client, AbstractRequest $request,
         }
         $errorCode = $response->getErrorCode();
         if (!ErrorCode::success($errorCode)) {
-            $client->close();
+            $client->connect();
             if ($retry > 0 && ErrorCode::canRetry($errorCode)) {
                 if ($sleep > 0) {
                     usleep((int) ($sleep * 1000000));

Original file line number	Diff line number	Diff line change
`@@ -66,7 +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`	`+ $client->connect();`
`70`	`70`	`if ($retry > 0 && ErrorCode::canRetry($errorCode)) {`
`71`	`71`	`if ($sleep > 0) {`
`72`	`72`	`usleep((int) ($sleep * 1000000));`