(rocketmq) branch develop updated: [ISSUE #10005] Fix switch-case logic in updateConsumerOffsetAsync (#10006)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 45fc4e0c7b [ISSUE #10005] Fix switch-case logic in 
updateConsumerOffsetAsync (#10006)
45fc4e0c7b is described below

commit 45fc4e0c7b1b06066bff2177120171aa70ce686d
Author: yx9o <yangx_s...@163.com>
AuthorDate: Thu Jan 15 10:58:35 2026 +0800

    [ISSUE #10005] Fix switch-case logic in updateConsumerOffsetAsync (#10006)
---
 .../apache/rocketmq/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;