From 45fc4e0c7b1b06066bff2177120171aa70ce686d Mon Sep 17 00:00:00 2001
From: yx9o <yangx_soft@163.com>
Date: Thu, 15 Jan 2026 10:58:35 +0800
Subject: [PATCH] [ISSUE #10005] Fix switch-case logic in
 updateConsumerOffsetAsync (#10006)

---
 .../client/impl/mqclient/MQClientAPIExt.java         | 12 +++++-------
 1 file changed, 5 insertions(+), 7 deletions(-)

diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIExt.java b/client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIExt.java
index 9089503407..7442e89cca 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIExt.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIExt.java
@@ -429,14 +429,12 @@ public class MQClientAPIExt extends MQClientAPIImpl {
                 return;
             }
             switch (response.getCode()) {
-                case ResponseCode.SUCCESS: {
+                case ResponseCode.SUCCESS:
                     future.complete(null);
-                }
-                case ResponseCode.SYSTEM_ERROR:
-                case ResponseCode.SUBSCRIPTION_GROUP_NOT_EXIST:
-                case ResponseCode.TOPIC_NOT_EXIST: {
-                    future.completeExceptionally(new MQBrokerException(response.getCode(), response.getRemark()));
-                }
+                    break;
+                default:
+                    future.completeExceptionally(new MQBrokerException(response.getCode(), response.getRemark(), brokerAddr));
+                    break;
             }
         });
         return future;