Skip to content

Commit 5ad1b2d

Browse files
committed
修复重置消费进度时,没有Check订阅组是否存在的bug
1 parent e1dd5fb commit 5ad1b2d

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

rocketmq-broker/src/main/java/com/alibaba/rocketmq/broker/client/net/Broker2Client.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -157,6 +157,12 @@ public RemotingCommand resetOffset(String topic, String group, long timeStamp, b
157157

158158
long consumerOffset =
159159
this.brokerController.getConsumerOffsetManager().queryOffset(group, topic, i);
160+
if (-1 == consumerOffset) {
161+
response.setCode(ResponseCode.SYSTEM_ERROR);
162+
response.setRemark(String.format("THe consumer group <%s> not exist", group));
163+
return response;
164+
}
165+
160166
long timeStampOffset =
161167
this.brokerController.getMessageStore().getOffsetInQueueByTime(topic, i, timeStamp);
162168
if (isForce || timeStampOffset < consumerOffset) {

0 commit comments

Comments
 (0)