1.bug fix:fix consumer missing bizNo

apache · Feb 1, 2021 · 0e8c1a0 · 0e8c1a0
1 parent f9e7b83
commit 0e8c1a0
Showing 1 changed file with 1 addition and 1 deletion.
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()));