Merge pull request #210 from WeBankFinTech/1.2.0

fix consumer missing bizNo
apache · Feb 2, 2021 · 05f7d36 · 05f7d36
2 parents 2643c9e + 60ba2a0
commit 05f7d36
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...connector-defibus/src/main/java/com/webank/eventmesh/connector/defibus/utils/OMSUtil.java b/...connector-defibus/src/main/java/com/webank/eventmesh/connector/defibus/utils/OMSUtil.java
@@ -128,7 +128,7 @@ public static BytesMessage msgConvert(org.apache.rocketmq.common.message.Message
 
         omsMsg.putSysHeaders(BuiltinKeys.MESSAGE_ID, rmqMsg.getMsgId());
         omsMsg.putSysHeaders(BuiltinKeys.DESTINATION, rmqMsg.getTopic());
-        omsMsg.putSysHeaders(BuiltinKeys.SEARCH_KEYS, rmqMsg.getKeys());
+//        omsMsg.putSysHeaders(BuiltinKeys.SEARCH_KEYS, rmqMsg.getKeys());
         omsMsg.putSysHeaders(BuiltinKeys.BORN_HOST, String.valueOf(rmqMsg.getBornHost()));
         omsMsg.putSysHeaders(BuiltinKeys.BORN_TIMESTAMP, rmqMsg.getBornTimestamp());
         omsMsg.putSysHeaders(BuiltinKeys.STORE_HOST, String.valueOf(rmqMsg.getStoreHost()));

diff --git a/...nnector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/utils/OMSUtil.java b/...nnector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/utils/OMSUtil.java
@@ -101,7 +101,7 @@ public static BytesMessage msgConvert(MessageExt rmqMsg) {
 
         omsMsg.putSysHeaders(BuiltinKeys.DESTINATION, rmqMsg.getTopic());
 
-        omsMsg.putSysHeaders(BuiltinKeys.SEARCH_KEYS, rmqMsg.getKeys());
+//        omsMsg.putSysHeaders(BuiltinKeys.SEARCH_KEYS, rmqMsg.getKeys());
         omsMsg.putSysHeaders(BuiltinKeys.BORN_HOST, String.valueOf(rmqMsg.getBornHost()));
         omsMsg.putSysHeaders(BuiltinKeys.BORN_TIMESTAMP, rmqMsg.getBornTimestamp());
         omsMsg.putSysHeaders(BuiltinKeys.STORE_HOST, String.valueOf(rmqMsg.getStoreHost()));