1.bug fix: fix rocketmq consumer missing bizNo

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