[rocketmq] branch develop updated: [ISSUE #5869] Remove unnecessary verification logic in consumerSendMsgBack method (#5868)

[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 7694a69d5 [ISSUE #5869] Remove unnecessary verification logic in 
consumerSendMsgBack method (#5868)
7694a69d5 is described below

commit 7694a69d599c7b406a26fc35560e3ad01a6755a7
Author: rongtong <jinrongto...@163.com>
AuthorDate: Wed Jan 11 19:49:01 2023 +0800

    [ISSUE #5869] Remove unnecessary verification logic in consumerSendMsgBack 
method (#5868)
---
 .../rocketmq/broker/processor/AbstractSendMessageProcessor.java  | 9 ---------
 1 file changed, 9 deletions(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
index 933a8984b..b348ecb8f 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
@@ -161,15 +161,6 @@ public abstract class AbstractSendMessageProcessor 
implements NettyRequestProces
             return response;
         }
 
-        //for logic queue
-        if (requestHeader.getOriginTopic() != null
-            && !msgExt.getTopic().equals(requestHeader.getOriginTopic())) {
-            //here just do some fence in case of some unexpected offset is 
income
-            response.setCode(ResponseCode.SYSTEM_ERROR);
-            response.setRemark("look message by offset failed to check the 
topic name" + requestHeader.getOffset());
-            return response;
-        }
-
         final String retryTopic = 
msgExt.getProperty(MessageConst.PROPERTY_RETRY_TOPIC);
         if (null == retryTopic) {
             MessageAccessor.putProperty(msgExt, 
MessageConst.PROPERTY_RETRY_TOPIC, msgExt.getTopic());