Skip to content

Commit 45fc4e0

Browse files
authored
[ISSUE #10005] Fix switch-case logic in updateConsumerOffsetAsync (#10006)
1 parent 3d3a2d0 commit 45fc4e0

1 file changed

Lines changed: 5 additions & 7 deletions

File tree

client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIExt.java

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -429,14 +429,12 @@ public CompletableFuture<Void> updateConsumerOffsetAsync(
429429
return;
430430
}
431431
switch (response.getCode()) {
432-
case ResponseCode.SUCCESS: {
432+
case ResponseCode.SUCCESS:
433433
future.complete(null);
434-
}
435-
case ResponseCode.SYSTEM_ERROR:
436-
case ResponseCode.SUBSCRIPTION_GROUP_NOT_EXIST:
437-
case ResponseCode.TOPIC_NOT_EXIST: {
438-
future.completeExceptionally(new MQBrokerException(response.getCode(), response.getRemark()));
439-
}
434+
break;
435+
default:
436+
future.completeExceptionally(new MQBrokerException(response.getCode(), response.getRemark(), brokerAddr));
437+
break;
440438
}
441439
});
442440
return future;

0 commit comments

Comments
 (0)