https://gitcode.net/apacherocketmq/rocketmq/-/commit/cf8b84659fbf5ca22c31fa336a615843f98fde01Polish the lock and persist for updateTopicQueueMapping2021-11-20T12:33:15+08:00dongeforeverdongeforever@apache.orghttps://gitcode.net/apacherocketmq/rocketmq/-/commit/401843579e7d70ef900a02808bebb5c29277b2cdPolish the static topic command2021-11-20T12:51:20+08:00dongeforeverdongeforever@apache.orghttps://gitcode.net/apacherocketmq/rocketmq/-/commit/daf47490c3e26720762534462c41a77b15e97ea2Polish the use of route data2021-11-20T13:20:39+08:00dongeforeverdongeforever@apache.org
@@ -135,7 +135,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement
...
@@ -135,7 +135,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement
returnbuildErrorResponse(ResponseCode.NOT_LEADER_FOR_QUEUE,String.format("%s-%d does not exit in request process of current broker %s",mappingContext.getTopic(),mappingContext.getGlobalId(),mappingDetail.getBname()));
returnbuildErrorResponse(ResponseCode.NOT_LEADER_FOR_QUEUE,String.format("%s-%d does not exit in request process of current broker %s",mappingContext.getTopic(),mappingContext.getGlobalId(),mappingDetail.getBname()));
returnbuildErrorResponse(ResponseCode.NOT_LEADER_FOR_QUEUE,String.format("%s-%d convert offset error in current broker %s",mappingContext.getTopic(),mappingContext.getGlobalId(),mappingDetail.getBname()));
returnbuildErrorResponse(ResponseCode.NOT_LEADER_FOR_QUEUE,String.format("%s-%d convert offset error in current broker %s",mappingContext.getTopic(),mappingContext.getGlobalId(),mappingDetail.getBname()));