1.bug fix: fix rocketmq consumer missing bizNo

xwm1992 · Feb 2, 2021 · b34d1ee · b34d1ee
1 parent 8f03048
commit b34d1ee
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()));