#EC_HJ131# 大数据MQ优化

src/weaver/interfaces/dito/mq/HrmRocketmqServlet.java

@@ -69,8 +69,6 @@ public class HrmRocketmqServlet extends HttpServlet {
                 if(StringUtils.isNotBlank(hostAddress) && StringUtils.isNotBlank(hostAddress) && hostAddress.equals(hrmMqRunIP)){
                     bb.writeLog("initData");
                     initData();
-
-
                 }
 
 //                if (isMainIp) {
@@ -119,7 +117,8 @@ public class HrmRocketmqServlet extends HttpServlet {
 //            String instanceName = propBean.getUfPropValueStatic("instanceName");
 //            bb.writeLog("instanceName:" + instanceName);
             consumer.setInstanceName(hrmInstanceName);
-            consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);
+            consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
+
 //            String topic = propBean.getUfPropValueStatic("topic");
 //            String subExpression = propBean.getUfPropValueStatic("subExpression");
 //            bb.writeLog("topic:" + topic);
@@ -139,9 +138,9 @@ public class HrmRocketmqServlet extends HttpServlet {
             consumer.setClusterName(hrmMQClusterName);
             consumer.setTenantID(hrmMQTenantID);
 
-//            consumer.setConsumeThreadMin(1);
-//            consumer.setConsumeThreadMax(1);
-//            consumer.setConsumeMessageBatchMaxSize(1);
+            consumer.setConsumeThreadMin(1);
+            consumer.setConsumeThreadMax(1);
+            consumer.setConsumeMessageBatchMaxSize(1);
 
             consumer.setMessageModel(MessageModel.CLUSTERING);
             consumer.registerMessageListener(new HrmRocketMsgListener3());